Page History

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);
    }
 
    ...
}