Table of Contents

Class ConsumerInterceptor

Namespace
Org.Apache.Kafka.Clients.Consumer
Assembly
MASES.KNet.dll
public class ConsumerInterceptor : JVMBridgeListener, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition
Inheritance
JVMBridgeBase
JVMBridgeBase<JVMBridgeListener>
JVMBridgeListener
ConsumerInterceptor
Implements
IJVMBridgeCore
IJVMBridgeBaseStatic
IJVMBridgeBase
IJVMBridgeDefinition
Derived
Inherited Members
JVMBridgeListener.Dispose()
JVMBridgeListener.AutoInit
JVMBridgeListener.IsBridgeStatic
JVMBridgeListener.IsBridgeCloseable
JVMBridgeListener.IsBridgeListener
JVMBridgeBase<JVMBridgeListener>.IsAssignableFrom(IJavaType)
JVMBridgeBase<JVMBridgeListener>.IsAssignableFrom<T>()
JVMBridgeBase<JVMBridgeListener>.Execute<T>(params T[])
JVMBridgeBase<JVMBridgeListener>.DynBridgeClazz
JVMBridgeBase<JVMBridgeListener>.BridgeClazz
JVMBridgeBase.RuntimeClassNameOf<T>()
JVMBridgeBase.ClassNameOf<T>()
JVMBridgeBase.ClassOf<T>()
JVMBridgeBase.WrapsDirect<TNewClass>(IJavaObject)
JVMBridgeBase.Wraps<TNewClass>(IJavaObject)
JVMBridgeBase.Wraps<TNewClass, TReturn>(IJavaObject)
JVMBridgeBase.Wraps<TNewClass, TReturn, TConverter>(IJavaObject)
JVMBridgeBase.MonitorEnter()
JVMBridgeBase.MonitorExit()
JVMBridgeBase.IsInstanceOf(IJavaType)
JVMBridgeBase.IsInstanceOf<T>()
JVMBridgeBase.RuntimeIsInstanceOf<T>()
JVMBridgeBase.CastTo<TNewClass>()
JVMBridgeBase.CastDirect<TNewClass>()
JVMBridgeBase.ToString()
JVMBridgeBase.GetHashCode()
JVMBridgeBase.Notify()
JVMBridgeBase.NotifyAll()
JVMBridgeBase.Wait()
JVMBridgeBase.DynBridgeInstance
JVMBridgeBase.BridgeInstance
JVMBridgeBase.IsBridgeInterface
JVMBridgeBase.IsBridgeAbstract

Constructors

ConsumerInterceptor()

Default constructor: even if the corresponding Java class does not have one, it is mandatory for JCOBridge

public ConsumerInterceptor()

Properties

BridgeClassName

public override string BridgeClassName { get; }

Property Value

string

OnClose

public Action OnClose { get; set; }

Property Value

Action

Remarks

If OnClose has a value it takes precedence over corresponding class method

OnConfigure

public Action<Map> OnConfigure { get; set; }

Property Value

Action<Map>

Remarks

If OnConfigure has a value it takes precedence over corresponding class method

OnOnCommit

public Action<Map> OnOnCommit { get; set; }

Property Value

Action<Map>

Remarks

If OnOnCommit has a value it takes precedence over corresponding class method

OnOnConsume

public Func<ConsumerRecords, ConsumerRecords> OnOnConsume { get; set; }

Property Value

Func<ConsumerRecords, ConsumerRecords>

Remarks

If OnOnConsume has a value it takes precedence over corresponding class method

Methods

Close()

public virtual void Close()

Configure(Map)

public virtual void Configure(Map arg0)

Parameters

arg0 Map

Map

InitializeHandlers()

Handlers initializer for ConsumerInterceptor

protected virtual void InitializeHandlers()

OnCommit(Map)

public virtual void OnCommit(Map arg0)

Parameters

arg0 Map

Map

OnConsume(ConsumerRecords)

public virtual ConsumerRecords OnConsume(ConsumerRecords arg0)

Parameters

arg0 ConsumerRecords

ConsumerRecords

Returns

ConsumerRecords

ConsumerRecords