java - 使用 Kafka 高级消费者时，有没有办法收到重新平衡通知？

Question

当使用java Kafka(0.8)高级消费者时，有没有办法确定已经或需要发生重新平衡？

谢谢!

Answer 1

正如 Cesar 上面提到的，没有干净的方法来获取有关重新平衡的通知。但请注意，当读取器或代理连接或断开连接以及主题的分区数量发生变化时，就会发生重新平衡。因此您可以监控注册代理和读取器的 Zookeeper 节点。请注意，它可能很脆弱，因为 Kafka 相关的 ZK 节点布局可能会在未来的 Kafka 版本中发生变化。

请参阅 Kafka docs 中的代理节点注册表、消费者 ID 注册表和分区所有者注册表部分。

此外，这并不是立即显而易见的，但重新平衡可能会失败，并且高级消费者可能会抛出 ConsumerRebalanceFailedException。所以这也是你需要考虑的事情。请参阅Kafka rebalancing了解重新平衡过程的高级概述。