小懶小幸福²☯¹⁸

怎样解决的，我也遇到类似问题

谢谢  已解决

就算分区分配到了   但logstash还是消费不到kafka集群的消息

[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

都消费不到