[org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] Setting newly assigned partitions [] for group logstash

[2018-05-23T10:29:08,000][INFO ][org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] Setting newly assigned partitions [] for group logstash
主题设置多分区多分本logstash就配置不到分区 这是什么没配置好吗






发表于: 6月前   最后更新时间: 6月前   游览量:637
上一条: 到头了!
下一条: 已经是最后了!

评论…


  • 怎么解决的?
    你的日志看着是正常的。
    一个都没分到应该排查其他问题了。
    • [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

      • 评论…
        • in this conversation