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 onPartitionsAssigned(Collection<TopicPartition> partitions) {
this.revokedPartitions = partitions;
}
@Override
public void onPartitionsRevoked(Collection<TopicPartition> partitions) {
this.revokedPartitions.removeAll(partitions);
cleanup(this.revokedPartitions);
}
...
} |
...