(Sorry for the attachments :)Re:New Consumer, use kafka-console-consumer.sh cannot consumer topics, because of joined group failed.

[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.