apache-kafka - kafka 主题分区再平衡通知

Question

我正在使用 Kafka 0.8.1.1

是否有任何 API（回调等）可以用来找到消费者lost partitions或消费者？newly added partitions

Answer 1

我正在使用 Kafka 0.9.1 API，并且有一个接口 ConsumerRebalanceListener 有两种方法

public void onPartitionsRevoked(Collection partitions) 其中

partitions上次重新平衡时分配给消费者的分区列表

public void onPartitionsAssigned（集合分区）

partitions现在分配给消费者的分区列表（可能包括以前分配给消费者的分区）