Class StreamsRebalanceListener
- java.lang.Object
-
- org.apache.kafka.streams.processor.internals.StreamsRebalanceListener
-
- All Implemented Interfaces:
org.apache.kafka.clients.consumer.ConsumerRebalanceListener
public class StreamsRebalanceListener extends java.lang.Object implements org.apache.kafka.clients.consumer.ConsumerRebalanceListener
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
onPartitionsAssigned(java.util.Collection<org.apache.kafka.common.TopicPartition> partitions)
void
onPartitionsLost(java.util.Collection<org.apache.kafka.common.TopicPartition> partitions)
void
onPartitionsRevoked(java.util.Collection<org.apache.kafka.common.TopicPartition> partitions)
-
-
-
Method Detail
-
onPartitionsAssigned
public void onPartitionsAssigned(java.util.Collection<org.apache.kafka.common.TopicPartition> partitions)
- Specified by:
onPartitionsAssigned
in interfaceorg.apache.kafka.clients.consumer.ConsumerRebalanceListener
-
onPartitionsRevoked
public void onPartitionsRevoked(java.util.Collection<org.apache.kafka.common.TopicPartition> partitions)
- Specified by:
onPartitionsRevoked
in interfaceorg.apache.kafka.clients.consumer.ConsumerRebalanceListener
-
onPartitionsLost
public void onPartitionsLost(java.util.Collection<org.apache.kafka.common.TopicPartition> partitions)
- Specified by:
onPartitionsLost
in interfaceorg.apache.kafka.clients.consumer.ConsumerRebalanceListener
-
-