问答详情
源自:4-3 kafka代码案例

消费重复的问题

搭建kafka后,机器之间测试可以,但是会重复打印消费的信息:“Auto offset commit failed for group test-consumer-group: Commit cannot be completed since the group has already rebalanced and assigned the partitions to another member. This means that the time between subsequent calls to poll() was longer than the configured session.timeout.ms, which typically implies that the poll loop is spending too much time message processing. You can address this either by increasing the session timeout or by reducing the maximum size of batches returned in poll() with max.poll.records.”写不开了,您的demo能发一下参考参考么?万分感谢

提问者:MOKERONE 2019-07-12 15:57

个回答

  • ChengHaoo
    2019-11-04 16:05:53

    没看到源码地址在哪里呀?

  • 懂渊
    2019-07-14 11:34:39

    课程开始介绍不是给了gituh 的项目源码地址了?