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

小懶小幸福²☯¹⁸ 发表于: 2018-05-23   最后更新时间: 2018-05-23  
  •   0 订阅,167 游览

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







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

评论…


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