消费重复的问题

来源:4-3 kafka代码案例

MOKERONE

2019-07-12 15:57

搭建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能发一下参考参考么?万分感谢

写回答 关注

2回答

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

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

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

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

Kafka流处理平台

作为模块解耦和大数据处理黏合剂的不二之选Kafka,你值得拥有!

33838 学习 · 49 问题

查看课程

相似问题