Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Rocketmq-client-go v2.1.2 creates a topic, but the newly created topic name does not exist.??? #1121

Open
xiaosong372089396 opened this issue Dec 21, 2023 · 0 comments

Comments

@xiaosong372089396
Copy link

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

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant