使用原生API发送消息出错
来源:12-3 【边学边做】使用原生API发送消息(1)

CaesarChen
2019-12-18
一哥你好,初次学习kafka,这里执行完代码之后消费者那里并未接收到我发送的 “ForgetResult”,然后我想是不是出现在我第一次创建的consumer里,因为中午吃完饭网断了下又重连新创建了consumer,如果是这个问题我该怎么进入到指定的那个consumer里呢?望指教,谢谢。
写回答
1回答
-
同学你好:
我不确定你的这个消息是不是已经被消费过了,如果被消费了,需要查它的 pos,这是很麻烦的,而且如果是测试的话,重新发个消息就好了,没必要去定位这里的问题。
欢迎来 QQ 群随时交流、讨论,也非常感谢同学的支持!
112019-12-18
相似问题