返回到文章

采纳

编辑于

kafka新建topic无法使用新的group消费

kafka

我的consumer在新建一个新的topic和groupid后无法接收到客户端发送的消息,这个问题只会在新建topic并且使用新的gropid时才会复现。
比方说:原本我有一个topic=test、groupid=test-group-id,这个topic和groupid可以正常接收消息。
但是我新建一个topic=test2、groupid=test2-group-id时就无法接收到消息。
紧接着我把配置文件调整成topic=test2、groupid=test-group-id时就能正常接收到消息了。
也就是说我新建topic没问题,但是groupid还得用原来的才能正常消息,请问有人遇到过这种问题吗?