apache / apache/rocketmq-client-go
Rocketmq-client-go v2.1.2 creates a topic, but the newly created topic name does not exist.???
Open
- Dominant language
- Go
- Stars
- 1.4k
- Forks
- 445
- PR merge metrics
- No merged PRs in 30d
Description
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
Contributor guide
Assessment
This issue has not been assessed yet.