apache / apache/rocketmq-client-go

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

Open
#1,121 0 comments 0 reactions 0 assignees View on GitHub
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

Open the contributing guide

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.