Interface IConsumerInterceptor<K, V>

Namespace

Org.Apache.Kafka.Clients.Consumer

Assembly

MASES.KNet.dll

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

public interface IConsumerInterceptor<K, V> : IJVMBridgeBase, IJVMBridgeDefinition

Type Parameters

K

V

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

Close()

This is called when interceptor is closed

void Close()

Configure(Map<string, Object>)

Configure this class with the given key-value pairs

void Configure(Map<string, Object> configs)

Parameters

configs Map<string, Object>

The configuration Map

OnCommit(Map<TopicPartition, OffsetAndMetadata>)

This is called when offsets get committed.

void OnCommit(Map<TopicPartition, OffsetAndMetadata> offsets)

Parameters

offsets Map<TopicPartition, OffsetAndMetadata>

A Map of offsets by partition with associated metadata

OnConsume(ConsumerRecords<K, V>)

This is called just before the records are returned by Poll(Duration)

ConsumerRecords<K, V> OnConsume(ConsumerRecords<K, V> records)

Parameters

records ConsumerRecords<K, V>

records records to be consumed by the client or records returned by the previous interceptors in the list

Returns

ConsumerRecords<K, V>

records that are either modified by the interceptor or same as records passed to this method