com.opendxl.databus.consumer

Class NoOpConsumerRebalanceListener

java.lang.Object

com.opendxl.databus.consumer.NoOpConsumerRebalanceListener

All Implemented Interfaces:

ConsumerRebalanceListener

public class NoOpConsumerRebalanceListener
extends java.lang.Object
implements ConsumerRebalanceListener

A non-functional implementation of ConsumerRebalanceListener

Constructor Summary

Constructors

Constructor and Description
NoOpConsumerRebalanceListener()

Method Summary

Modifier and Type	Method and Description
void	onPartitionsAssigned(java.util.Collection<TopicPartition> partitions) A callback method the user can implement to provide handling of customized offsets on completion of a successful partition re-assignment.
void	onPartitionsRevoked(java.util.Collection<TopicPartition> partitions) A callback method the user can implement to provide handling of offset commits to a customized store on the start of a rebalance operation.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

NoOpConsumerRebalanceListener

public NoOpConsumerRebalanceListener()

Method Detail

onPartitionsRevoked

public void onPartitionsRevoked(java.util.Collection<TopicPartition> partitions)

Description copied from interface: ConsumerRebalanceListener

A callback method the user can implement to provide handling of offset commits to a customized store on the start of a rebalance operation. This method will be called before a rebalance operation starts and after the consumer stops fetching data. It is recommended that offsets should be committed in this callback to either Kafka or a custom offset store to prevent duplicate data.

For examples on usage of this API, see Usage Examples section of Consumer

NOTE: This method is only called before rebalances. It is not called prior to Consumer.close().

Specified by:

onPartitionsRevoked in interface ConsumerRebalanceListener

Parameters:

partitions - The list of partitions that were assigned to the consumer on the last rebalance

onPartitionsAssigned

public void onPartitionsAssigned(java.util.Collection<TopicPartition> partitions)

Description copied from interface: ConsumerRebalanceListener

A callback method the user can implement to provide handling of customized offsets on completion of a successful partition re-assignment. This method will be called after an offset re-assignment completes and before the consumer starts fetching data.

It is guaranteed that all the processes in a consumer group will execute their ConsumerRebalanceListener.onPartitionsRevoked(Collection) callback before any getInstance executes its ConsumerRebalanceListener.onPartitionsAssigned(Collection) callback.

Specified by:

onPartitionsAssigned in interface ConsumerRebalanceListener

Parameters:

partitions - The list of partitions that are now assigned to the consumer (may include partitions previously assigned to the consumer)