Interface IConsumerRebalanceListener

Namespace

Org.Apache.Kafka.Clients.Consumer

Assembly

MASES.KNet.dll

Listener for Kafka ConsumerRebalanceListener. Extends MASES.JCOBridge.C2JBridge.IJVMBridgeBase

public interface IConsumerRebalanceListener : IJVMBridgeBase, IJVMBridgeDefinition

Inherited Members

IJVMBridgeBase.MonitorEnter()

IJVMBridgeBase.MonitorExit()

IJVMBridgeBase.IsInstanceOf(string)

IJVMBridgeBase.IsInstanceOf(IJavaType)

IJVMBridgeBase.IsInstanceOf<T>()

IJVMBridgeBase.RuntimeIsInstanceOf<T>()

IJVMBridgeBase.CastTo<TNewClass>()

IJVMBridgeBase.CastDirect<TNewClass>()

IJVMBridgeBase.DynBridgeInstance

IJVMBridgeBase.BridgeInstance

IJVMBridgeDefinition.BridgeClassName

IJVMBridgeDefinition.IsBridgeInterface

IJVMBridgeDefinition.IsBridgeAbstract

IJVMBridgeDefinition.IsBridgeStatic

IJVMBridgeDefinition.IsBridgeCloseable

IJVMBridgeDefinition.IsBridgeListener

Methods

OnPartitionsAssigned(Collection<TopicPartition>)

Executes the Callback action in the CLR

void OnPartitionsAssigned(Collection<TopicPartition> partitions)

Parameters

partitions Collection<TopicPartition>

The Collection<E> object

OnPartitionsRevoked(Collection<TopicPartition>)

Executes the Callback action in the CLR

void OnPartitionsRevoked(Collection<TopicPartition> partitions)

Parameters

partitions Collection<TopicPartition>

The Collection<E> object