1 package de.juplo.kafka;
3 import lombok.RequiredArgsConstructor;
4 import org.apache.kafka.clients.consumer.ConsumerRebalanceListener;
5 import org.apache.kafka.common.TopicPartition;
7 import java.util.Collection;
10 @RequiredArgsConstructor
11 public class WordcountRebalanceListener implements ConsumerRebalanceListener
13 private final RecordHandler<String, String> handler;
17 public void onPartitionsAssigned(Collection<TopicPartition> partitions)
19 partitions.forEach(tp -> handler.onPartitionAssigned(tp));
23 public void onPartitionsRevoked(Collection<TopicPartition> partitions)
25 partitions.forEach(tp -> handler.onPartitionRevoked(tp));