Kafka重平衡导致无限循环消费问题
通过消费组管理消费者时,该配置指定拉取消息线程最长空闲时间,若超过这个时间间隔没有发起poll操作,则消费组认为该消费者已离开了消费组,将进行再均衡操作(将分区分配给组内其他消费者成员)kafka默认的消息消费超时时间max.poll.interval.ms = 300000, 也就是5分钟,超过5
通过消费组管理消费者时,该配置指定拉取消息线程最长空闲时间,若超过这个时间间隔没有发起poll操作,则消费组认为该消费者已离开了消费组,将进行再均衡操作(将分区分配给组内其他消费者成员)kafka默认的消息消费超时时间max.poll.interval.ms = 300000, 也就是5分钟,超过5