问题：在有大量消息需要消费时，消费端出现报错：org.apache.kafka.clients.consumer.CommitFailedException:Commitcannotbecompletedsincethegrouphasalreadyrebalancedandassignedthepartitionstoanothermember.Thismeansthatthetimebetweensubsequentcallstopoll()waslongerthantheconfiguredmax.poll.interval.ms,whichtypicallyimpliesthatthe

创建多个消费者(使用Kafka0.9javaAPI)并启动每个线程后，出现以下异常Consumerhasfailedwithexception:org.apache.kafka.clients.consumer.CommitFailedException:Commitcannotbecompletedduetogrouprebalanceclasscom.messagehub.consumer.Consumerisshuttingdown.org.apache.kafka.clients.consumer.CommitFailedException:Commitcannotbecomp

大家好，我是三叔，很高兴这期又和大家见面了，一个奋斗在互联网的打工人。记一次kafka生产Bug：CommitFailedExceptionkafka消费端消费消息出现多次同一个消息推送给后台离线处理平台，且消息消费越来越慢。于是查看生产日志，发现了有重复消费的ID，且offset都是一样的。一开始怀疑是因为后台处理数据失败，调度对失败的消息进行重试，那么问题来了：如果是重试，那么发送到kafka消息的offset应该是不一样的，但是查看日志发现，重复消费的消息id和offset一模一样，于是查看日志后面的error信息：CommitFailedException:offsetcommitca

我使用的是kafka0.10.2，现在遇到了CommitFailedException。喜欢:Commitcannotbecompletedsincethegrouphasalreadyrebalancedandassignedthepartitionstoanothermember.Thismeansthatthetimebetweensubsequentcallstopoll()waslongerthantheconfiguredmax.poll.interval.ms,whichtypicallyimpliesthatthepollloopisspendingtoomuchtim