【发布时间】:2021-07-06 19:09:13
【问题描述】:
我将 Kafka 用于我的 Web 应用程序,我在 kafka.log 中找到了以下消息:
[2021-07-06 08:49:03,658] INFO [GroupCoordinator 0]: Preparing to rebalance group qpcengine-group in state PreparingRebalance with old generation 105 (__consumer_offsets-28) (reason: removing member consumer-1-7eafeb56-e6fe-4161-9c88-e69c06a0ab37 on heartbeat expiration) (kafka.coordinator.group.GroupCoordinator)
[2021-07-06 08:49:03,658] INFO [GroupCoordinator 0]: Group qpcengine-group with generation 106 is now empty (__consumer_offsets-28) (kafka.coordinator.group.GroupCoordinator)
但是,对于一个消费者来说,kafka 就像永远循环一样。 我怎样才能阻止它?
这里是 kafka 日志的图片: enter image description here
【问题讨论】:
标签: spring-boot apache-kafka kafka-consumer-api spring-kafka