十禾

0 声望

这家伙太懒,什么都没留下

个人动态

十禾 回复 半兽人 当轮询kafka的consumer重启的时候,可以从最新的offset开始消费 中 :

不好意思,回复完了。确实是因为没有消息写进来,看似没有订阅成功,应该是kafka sdk里面的订阅是个lazy操作,已经可以每次开始消费都从最新的offset了,问题解决了。就是1看不懂

2天前
半兽人 回复 十禾 当轮询kafka的consumer重启的时候,可以从最新的offset开始消费 中 :

1、因为你们用了同一个名字,所以你指定的offset的就报了刚才的错误呀,不是其成员。
2、消费者启成功后,生产者是否有持续的消息写到该topic呢?

17天前
十禾 回复 十禾 当轮询kafka的consumer重启的时候,可以从最新的offset开始消费 中 :

上面补充了查询kafka服务端的图

17天前
十禾 回复 半兽人 当轮询kafka的consumer重启的时候,可以从最新的offset开始消费 中 :

假设程序A和程序B以同一个消费者组名订阅这个分区的话,只有一个程序能消费到这我理解,怎么会有占用呢?然后我刚才去除别的实例的干扰,又查了下kafka服务端,发现虽然我调用了assign()方法,但是服务端并没有消费者,是否说明没订阅成功,为什么会没订阅成功呢?

17天前