Interface ConsumerAwareRebalanceListener
-
- All Superinterfaces:
org.apache.kafka.clients.consumer.ConsumerRebalanceListener
public interface ConsumerAwareRebalanceListener extends org.apache.kafka.clients.consumer.ConsumerRebalanceListenerA rebalance listener that provides access to the consumer object. Starting with version 2.1.5, as a convenience, default no-op implementations are provided for all methods, allowing the user to implement just those (s)he is interested in.- Since:
- 2.0
- Author:
- Gary Russell
-
-
Method Summary
All Methods Instance Methods Default Methods Modifier and Type Method Description default voidonPartitionsAssigned(java.util.Collection<org.apache.kafka.common.TopicPartition> partitions)default voidonPartitionsAssigned(org.apache.kafka.clients.consumer.Consumer<?,?> consumer, java.util.Collection<org.apache.kafka.common.TopicPartition> partitions)The same asonPartitionsAssigned(Collection)with the additional consumer parameter.default voidonPartitionsLost(java.util.Collection<org.apache.kafka.common.TopicPartition> partitions)default voidonPartitionsLost(org.apache.kafka.clients.consumer.Consumer<?,?> consumer, java.util.Collection<org.apache.kafka.common.TopicPartition> partitions)The same asonPartitionsLost(Collection)with an additional consumer parameter.default voidonPartitionsRevoked(java.util.Collection<org.apache.kafka.common.TopicPartition> partitions)default voidonPartitionsRevokedAfterCommit(org.apache.kafka.clients.consumer.Consumer<?,?> consumer, java.util.Collection<org.apache.kafka.common.TopicPartition> partitions)The same asonPartitionsRevoked(Collection)with the additional consumer parameter.default voidonPartitionsRevokedBeforeCommit(org.apache.kafka.clients.consumer.Consumer<?,?> consumer, java.util.Collection<org.apache.kafka.common.TopicPartition> partitions)The same asonPartitionsRevoked(Collection)with the additional consumer parameter.
-
-
-
Method Detail
-
onPartitionsRevokedBeforeCommit
default void onPartitionsRevokedBeforeCommit(org.apache.kafka.clients.consumer.Consumer<?,?> consumer, java.util.Collection<org.apache.kafka.common.TopicPartition> partitions)The same asonPartitionsRevoked(Collection)with the additional consumer parameter. It is invoked by the container before any pending offsets are committed.- Parameters:
consumer- the consumer.partitions- the partitions.
-
onPartitionsRevokedAfterCommit
default void onPartitionsRevokedAfterCommit(org.apache.kafka.clients.consumer.Consumer<?,?> consumer, java.util.Collection<org.apache.kafka.common.TopicPartition> partitions)The same asonPartitionsRevoked(Collection)with the additional consumer parameter. It is invoked by the container after any pending offsets are committed.- Parameters:
consumer- the consumer.partitions- the partitions.
-
onPartitionsLost
default void onPartitionsLost(org.apache.kafka.clients.consumer.Consumer<?,?> consumer, java.util.Collection<org.apache.kafka.common.TopicPartition> partitions)The same asonPartitionsLost(Collection)with an additional consumer parameter.- Parameters:
consumer- the consumer.partitions- the partitions.- Since:
- 2.4
-
onPartitionsAssigned
default void onPartitionsAssigned(org.apache.kafka.clients.consumer.Consumer<?,?> consumer, java.util.Collection<org.apache.kafka.common.TopicPartition> partitions)The same asonPartitionsAssigned(Collection)with the additional consumer parameter.- Parameters:
consumer- the consumer.partitions- the partitions.
-
onPartitionsRevoked
default void onPartitionsRevoked(java.util.Collection<org.apache.kafka.common.TopicPartition> partitions)
- Specified by:
onPartitionsRevokedin interfaceorg.apache.kafka.clients.consumer.ConsumerRebalanceListener
-
onPartitionsAssigned
default void onPartitionsAssigned(java.util.Collection<org.apache.kafka.common.TopicPartition> partitions)
- Specified by:
onPartitionsAssignedin interfaceorg.apache.kafka.clients.consumer.ConsumerRebalanceListener
-
onPartitionsLost
default void onPartitionsLost(java.util.Collection<org.apache.kafka.common.TopicPartition> partitions)
- Specified by:
onPartitionsLostin interfaceorg.apache.kafka.clients.consumer.ConsumerRebalanceListener
-
-