java吧 关注:1,207,234贴子:12,648,402
  • 1回复贴,共1

最近在学kafka 问一下消息积压的问题

只看楼主收藏回复

因为看见有解决办法是 对一个分区创建多个消费组 然后就有个问题 这样不是属于多播吗 大家都是各自消费
首先向broker中的Atopic的1分区发送了一条消息.有A和B两个消费组中的消费者去进行消费
怎么才能A消费了Atopic1分区的一条消息后提交偏移量1 B消费者消费后提交偏移量2
然后再A消费去继续读取偏移量2后去进行消费 提交偏移量3


IP属地:北京1楼2022-08-15 00:09回复
    有人吗


    IP属地:北京来自iPhone客户端2楼2022-08-15 11:38
    回复