THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block |
---|
public interface ConsumerRebalanceListener { void onPartitionsRevoked(Collection<TopicPartition> partitions); void onPartitionsAssigned(Collection<TopicPartition> partitions); // new API default void onPartitionsEmigrated(Collection<TopicPartition> partitions) { onPartitionsAssignedonPartitionsRevoked(Collection<TopicPartition> partitions); } } |
Consumer Coordinator Algorithm
...