rocketmq-client-go
rocketmq-client-go copied to clipboard
Rocketmq-client-go v2.1.2 creates a topic, but the newly created topic name does not exist.???
Use the rocketmq-client-go client to create a topic. The result returned is a success status, but the topic name does not exist in the cluster. Use examples/topic/main.go //create topic err = testAdmin.CreateTopic( context.Background(), admin.WithTopicCreate(topic), admin.WithBrokerAddrCreate(brokerAddr), ) if err != nil { fmt.Println("Create topic error:", err.Error()) }
INFO[0000] create topic success broker="10.140.40.4:10911" topic=newOne INFO[0000] Fetch all topic list success
Query the name of the newly created topic, it does not exist