相关疑难解决方法(0)

我在Kafka 0.10.0.1集群中有一个包含10个分区的主题.我有一个产生多个消费者线程的应用程序.对于这个主题,我产生了5个线程.在我的应用程序日志中,我多次看到此条目

INFO :: AbstractCoordinator:600 - Marking the coordinator x.x.x.x:9092
(id:2147483646 rack: null) dead for group notifications-consumer

然后有几个条目说(Re-)joining group notifications-consumer. Afterwards我也看到一个警告说

Auto commit failed for group notifications-consumer: 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
max.poll.interval.ms, which typically implies that the poll loop is spending too much time 
message processing. You can address this either …