[2018-05-23T16:08:29,559][INFO ][org.apache.kafka.clients.consumer.internals.AbstractCoordinator] Successfully joined group logstash with generation 26 [2018-05-23T16:08:29,560][INFO ][org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] Setting newly assigned partitions [xxx-1] for group logstash [2018-05-23T16:08:32,581][INFO ][org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] Revoking previously assigned partitions [xxx-1] for group logstash [2018-05-23T16:08:32,581][INFO ][org.apache.kafka.clients.consumer.internals.AbstractCoordinator] (Re-)joining group logstash [2018-05-23T16:09:02,572][INFO ][org.apache.kafka.clients.consumer.internals.AbstractCoordinator] Successfully joined group logstash with generation 27 [2018-05-23T16:09:02,572][INFO ][org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] Setting newly assigned partitions [xxx-2, xxx-0, xxx-1] for group logstash [2018-05-23T16:17:04,103][INFO ][org.apache.kafka.clients.consumer.internals.AbstractCoordinator] Marking the coordinator 47.96.21.52:9092 (id: 2147483647 rack: null) dead for group logstash [2018-05-23T16:17:04,236][INFO ][org.apache.kafka.clients.consumer.internals.AbstractCoordinator] Marking the coordinator 47.96.21.52:9092 (id: 2147483647 rack: null) dead for group logstash [2018-05-23T16:17:34,218][INFO ][org.apache.kafka.clients.consumer.internals.AbstractCoordinator] Marking the coordinator 47.96.21.52:9092 (id: 2147483647 rack: null) dead for group logstash [2018-05-23T16:17:34,275][INFO ][org.apache.kafka.clients.consumer.internals.AbstractCoordinator] Marking the coordinator 47.96.21.52:9092 (id: 2147483647 rack: null) dead for group logstash
你的日志看着是正常的。
一个都没分到应该排查其他问题了。
好的 谢谢
你好 当我多节点 多副本的时候会出现这问题 请问这是什么原因
你这个指的什么呢？有个别消费不到 还是都消费不到？
都消费不到
[2018-05-23T16:08:29,559][INFO ][org.apache.kafka.clients.consumer.internals.AbstractCoordinator] Successfully joined group logstash with generation 26
[2018-05-23T16:08:29,560][INFO ][org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] Setting newly assigned partitions [xxx-1] for group logstash
[2018-05-23T16:08:32,581][INFO ][org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] Revoking previously assigned partitions [xxx-1] for group logstash
[2018-05-23T16:08:32,581][INFO ][org.apache.kafka.clients.consumer.internals.AbstractCoordinator] (Re-)joining group logstash
[2018-05-23T16:09:02,572][INFO ][org.apache.kafka.clients.consumer.internals.AbstractCoordinator] Successfully joined group logstash with generation 27
[2018-05-23T16:09:02,572][INFO ][org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] Setting newly assigned partitions [xxx-2, xxx-0, xxx-1] for group logstash
[2018-05-23T16:17:04,103][INFO ][org.apache.kafka.clients.consumer.internals.AbstractCoordinator] Marking the coordinator 47.96.21.52:9092 (id: 2147483647 rack: null) dead for group logstash
[2018-05-23T16:17:04,236][INFO ][org.apache.kafka.clients.consumer.internals.AbstractCoordinator] Marking the coordinator 47.96.21.52:9092 (id: 2147483647 rack: null) dead for group logstash
[2018-05-23T16:17:34,218][INFO ][org.apache.kafka.clients.consumer.internals.AbstractCoordinator] Marking the coordinator 47.96.21.52:9092 (id: 2147483647 rack: null) dead for group logstash
[2018-05-23T16:17:34,275][INFO ][org.apache.kafka.clients.consumer.internals.AbstractCoordinator] Marking the coordinator 47.96.21.52:9092 (id: 2147483647 rack: null) dead for group logstash
就算分区分配到了 但logstash还是消费不到kafka集群的消息
谢谢 已解决
怎样解决的，我也遇到类似问题
怎么解决的？
你的答案