升级后kafka消费者不使用消息

hfwmuf9z  于 2021-06-07  发布在  Kafka
关注(0)|答案(0)|浏览(286)

我用go做了服务器升级到kafka0.11,sarama客户端升级到v1.13.0。我现在也在使用sarama集群而不是wvanbergen/kafka来管理消费者群体。请注意,kafka升级可与wvanbergen/kafka和旧版本的sarama客户端(v1.8)一起使用
我看到我的消费者没有消费任何消息,而且日志中有一行显示消费者组已经死亡。
以下是Kafka的日志:

2017-10-12 19:39:05,030 - INFO  [kafka-request-handler-7:Logging$class@70] - [GroupCoordinator 1]: Preparing to rebalance group job_event_consumer with old generation 0 (__consumer_offsets-5)
2017-10-12 19:39:05,032 - INFO  [kafka-request-handler-3:Logging$class@70] - [GroupCoordinator 1]: Preparing to rebalance group user_forwarder with old generation 0 (__consumer_offsets-20)
2017-10-12 19:39:08,031 - INFO  [executor-Rebalance:Logging$class@70] - [GroupCoordinator 1]: Stabilized group job_event_consumer generation 1 (__consumer_offsets-5)
2017-10-12 19:39:08,032 - INFO  [executor-Rebalance:Logging$class@70] - [GroupCoordinator 1]: Stabilized group user_forwarder generation 1 (__consumer_offsets-20)
2017-10-12 19:39:08,032 - INFO  [kafka-request-handler-5:Logging$class@70] - [GroupCoordinator 1]: Assignment received from leader for group job_event_consumer for generation 1
2017-10-12 19:39:08,033 - INFO  [kafka-request-handler-5:Logging$class@70] - [GroupCoordinator 1]: Assignment received from leader for group user_forwarder for generation 1
2017-10-12 19:39:15,743 - INFO  [kafka-request-handler-1:Logging$class@70] - [GroupCoordinator 1]: Preparing to rebalance group user_forwarder with old generation 1 (__consumer_offsets-20)
2017-10-12 19:39:15,744 - INFO  [kafka-request-handler-2:Logging$class@70] - [GroupCoordinator 1]: Preparing to rebalance group job_event_consumer with old generation 1 (__consumer_offsets-5)
2017-10-12 19:39:45,743 - INFO  [executor-Rebalance:Logging$class@70] - [GroupCoordinator 1]: Stabilized group user_forwarder generation 2 (__consumer_offsets-20)
2017-10-12 19:39:45,744 - INFO  [executor-Rebalance:Logging$class@70] - [GroupCoordinator 1]: Stabilized group job_event_consumer generation 2 (__consumer_offsets-5)
2017-10-12 19:39:47,043 - INFO  [executor-Heartbeat:Logging$class@70] - [GroupCoordinator 1]: Member mothership_staging-2c8c20d0-4a6b-4b41-b208-e822553bc9c7 in group user_forwarder has failed, removing it from the group
2017-10-12 19:39:47,044 - INFO  [executor-Heartbeat:Logging$class@70] - [GroupCoordinator 1]: Preparing to rebalance group user_forwarder with old generation 2 (__consumer_offsets-20)
2017-10-12 19:39:47,272 - INFO  [executor-Heartbeat:Logging$class@70] - [GroupCoordinator 1]: Member mothership_staging-31a167c1-f70e-4af6-a21d-da500149c084 in group job_event_consumer has failed, removing it from the group
2017-10-12 19:39:47,272 - INFO  [executor-Heartbeat:Logging$class@70] - [GroupCoordinator 1]: Preparing to rebalance group job_event_consumer with old generation 2 (__consumer_offsets-5)
2017-10-12 19:40:15,743 - INFO  [executor-Heartbeat:Logging$class@70] - [GroupCoordinator 1]: Member mothership_staging-7c1655dc-a7bc-4d39-b632-9af33c7ba934 in group user_forwarder has failed, removing it from the group
2017-10-12 19:40:15,744 - INFO  [executor-Heartbeat:Logging$class@70] - [GroupCoordinator 1]: Group user_forwarder with generation 3 is now empty (__consumer_offsets-20)
2017-10-12 19:40:15,745 - INFO  [executor-Heartbeat:Logging$class@70] - [GroupCoordinator 1]: Member mothership_staging-6ef84d2e-fca7-4c7c-920f-2b0d4ef8ec86 in group job_event_consumer has failed, removing it from the group
2017-10-12 19:40:15,746 - INFO  [executor-Heartbeat:Logging$class@70] - [GroupCoordinator 1]: Group job_event_consumer with generation 3 is now empty (__consumer_offsets-5)
2017-10-12 19:44:11,330 - INFO  [group-metadata-manager-0:Logging$class@70] - [Group Metadata Manager on Broker 1]: Group job_event_consumer transitioned to Dead in generation 3
2017-10-12 19:44:11,331 - INFO  [group-metadata-manager-0:Logging$class@70] - [Group Metadata Manager on Broker 1]: Group user_forwarder transitioned to Dead in generation 3

使用者或任何其他日志中没有错误。是什么导致了这个问题?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题