THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block |
---|
public class StickyAssignorConsumerRebalanceListener implements ConsumerRebalanceListener { ... private Collection<TopicPartition> revokedPartitions; @Override public void onPartitionsAssignedonPartitionsRevoked(Collection<TopicPartition> partitions) { this.revokedPartitions = partitions; } @Override public void onPartitionsRevokedonPartitionsAssigned(Collection<TopicPartition> partitions) { this.revokedPartitions.removeAll(partitions); cleanup(this.revokedPartitions); } ... } |
Rejected Alternatives
...