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
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