can not CreateTopic

[richzhu369]

can not create topic when i use rocketmq-client-go v2

import (
    "context"
    "fmt"
    "github.com/apache/rocketmq-client-go/v2/admin"
    "github.com/apache/rocketmq-client-go/v2/primitive"
    "log"
    "strings"
)

func CreateTopic() {
    endPoint := []string{"xxx:9876"}
    topicName := "RichTestTopic"
    // 创建topic
    testAdmin, err := admin.NewAdmin(admin.WithResolver(primitive.NewPassthroughResolver(endPoint)))
    // 检查是否连接成功
    if err != nil {
        fmt.Printf("connection error: %s\n", err.Error())
    }
    err = testAdmin.CreateTopic(context.Background(),
        admin.WithTopicCreate(topicName)),
                admin.WithBrokerAddrCreate("xxx:9876"),
    // 检查是否创建topic失败
    if err != nil {
        fmt.Printf("createTopic error: %s\n", err.Error())
    }
}

is showing create success, but when i check topic list , don't have that new one topic RichTestTopic

INFO[0005] create topic success

it's my code , get topic list

func getTopicList() {
    // RocketMQ NameServer 地址
    nameServerAddress := []string{"xxx:9876"}

    // 创建 RocketMQ 管理员客户端
    mqAdmin, err := admin.NewAdmin(
        admin.WithResolver(primitive.NewPassthroughResolver(nameServerAddress)),
    )
    if err != nil {
        log.Fatalf("创建管理员客户端失败: %sn", err)
    }
    defer mqAdmin.Close()

    // 获取 Topic 列表
    topicList, err := mqAdmin.FetchAllTopicList(context.Background())
    if err != nil {
        log.Fatalf("获取 Topic 列表失败: %sn", err)
    }
}

[richzhu369]

my code problem