rocketmq-client-go icon indicating copy to clipboard operation
rocketmq-client-go copied to clipboard

consumer will start failed when the subscribed topic not created

Open qshuai opened this issue 3 years ago • 3 comments

I hope the consumer client will hold on and start consuming when the topic created.

please add todo list!

qshuai avatar Feb 06 '23 03:02 qshuai

如果broker支持自动创建topic, 这个时候消费者会启动成功, 正常消费。 如果broker不支持自动创建topic,则会报topic不存在, 目前没有hold on, 有可能topic错了, 永远不会被创建, 消费者不应该一直hold on

francisoliverlee avatar Feb 07 '23 06:02 francisoliverlee

首先消费者不应该自动创建topic,topic创建时的参数(比如queue的数量)应该由生产者来指定。 其次,如果topic不存在,consumer hold住并没有什么坏处,hold住的这个行为也和kafka一样,没有什么不妥。

另外,你说有可能topic错了,那说topic是存在的情况,不在这个讨论范围里面

qshuai avatar Feb 07 '23 13:02 qshuai

如果broker支持自动创建topic, 这个时候消费者会启动成功, 正常消费。 如果broker不支持自动创建topic,则会报topic不存在, 目前没有hold on, 有可能topic错了, 永远不会被创建, 消费者不应该一直hold on

我测试了一下,目前的最新代码(master);我设置broker支持自动创建topic,当consumer subscribe一个不存在topic时,也并没有自动创建这个topic(报错信息: xxx route info not found, it may not exist)

qshuai avatar Feb 10 '23 04:02 qshuai