You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@kafka.apache.org by xd_zhaodong <xd...@163.com> on 2016/03/26 09:56:33 UTC
New Consumer, use kafka-console-consumer.sh cannot consumer topics,
because of joined group failed.
Hello all,
I am trying to consume some topic using kafka-console-consumer.sh.
The problem is, I can consume nothing for a long time. there some infinite print in the Client log like "SyncGroup for group example-group1 failed due to UNKNOWN_MEMBER_ID, rejoining the group".
the print in the Server log is
2016-03-26 16:33:22,561 | INFO | [executor-Heartbeat] | [GroupCoordinator 2]: Preparing to restabilize group example_gruoup1 with old generation 1 | kafka.coordinator.GroupCoordinator (Logging.scala:68)
2016-03-26 16:33:22,561 | INFO | [executor-Heartbeat] | [GroupCoordinator 2]: Group example_gruoup1 generation 1 is dead and removed | kafka.coordinator.GroupCoordinator (Logging.scala:68)
2016-03-26 16:33:22,562 | INFO | [kafka-request-handler-6] | [GroupCoordinator 2]: Preparing to restabilize group example_gruoup1 with old generation 0 | kafka.coordinator.GroupCoordinator (Logging.scala:68)
2016-03-26 16:33:22,563 | INFO | [kafka-request-handler-6] | [GroupCoordinator 2]: Stabilized group example_gruoup1 generation 1 | kafka.coordinator.GroupCoordinator (Logging.scala:68)
Detail see the attachments, don't care about the time between client and server log. (I did not collect the same time)
By the way, 1) producer works well.
2) the znode of example-group1 exist in zookeeper /kafka/consumers.
3) zookeeper works well.
(Sorry for the attachments :)Re:New Consumer, use
kafka-console-consumer.sh cannot consumer topics, because of joined group
failed.
Posted by xd_zhaodong <xd...@163.com>.
At 2016-03-26 16:56:33, "xd_zhaodong" <xd...@163.com> wrote:
>Hello all,
> I am trying to consume some topic using kafka-console-consumer.sh.
> The problem is, I can consume nothing for a long time. there some infinite print in the Client log like "SyncGroup for group example-group1 failed due to UNKNOWN_MEMBER_ID, rejoining the group".
> the print in the Server log is
>2016-03-26 16:33:22,561 | INFO | [executor-Heartbeat] | [GroupCoordinator 2]: Preparing to restabilize group example_gruoup1 with old generation 1 | kafka.coordinator.GroupCoordinator (Logging.scala:68)
>2016-03-26 16:33:22,561 | INFO | [executor-Heartbeat] | [GroupCoordinator 2]: Group example_gruoup1 generation 1 is dead and removed | kafka.coordinator.GroupCoordinator (Logging.scala:68)
>2016-03-26 16:33:22,562 | INFO | [kafka-request-handler-6] | [GroupCoordinator 2]: Preparing to restabilize group example_gruoup1 with old generation 0 | kafka.coordinator.GroupCoordinator (Logging.scala:68)
>2016-03-26 16:33:22,563 | INFO | [kafka-request-handler-6] | [GroupCoordinator 2]: Stabilized group example_gruoup1 generation 1 | kafka.coordinator.GroupCoordinator (Logging.scala:68)
>
>
> Detail see the attachments, don't care about the time between client and server log. (I did not collect the same time)
>
>
> By the way, 1) producer works well.
> 2) the znode of example-group1 exist in zookeeper /kafka/consumers.
> 3) zookeeper works well.