Table of Contents

Class ProducerInterceptor

Namespace
Org.Apache.Kafka.Clients.Producer
Assembly
MASES.KNet.dll
public class ProducerInterceptor : JVMBridgeListener, IDynamicMetaObjectProvider, IJVMBridgeCore, IEquatable<IJVMBridgeBase>, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition
Inheritance
ProducerInterceptor
Implements
Derived
Inherited Members

Constructors

ProducerInterceptor()

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

public ProducerInterceptor()

ProducerInterceptor(IJVMBridgeBaseInitializer)

Internal constructor: used internally from JCOBridge

[Obsolete("This public initializer is needed for JCOBridge internal use, other uses can produce unidentible behaviors.")]
public ProducerInterceptor(IJVMBridgeBaseInitializer initializer)

Parameters

initializer IJVMBridgeBaseInitializer

ProducerInterceptor(params object[])

Generic constructor: it is useful for JCOBridge when there is a derived class which needs to pass arguments to the highest JVMBridgeBase class

public ProducerInterceptor(params object[] args)

Parameters

args object[]

Properties

BridgeClassName

Java class name to be instantiated

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

OnOnAcknowledgement

public Action<RecordMetadata, JVMBridgeException, Headers> OnOnAcknowledgement { get; set; }

Property Value

Action<RecordMetadata, JVMBridgeException, Headers>

Remarks

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

OnOnAcknowledgement2

public Action<RecordMetadata, JVMBridgeException> OnOnAcknowledgement2 { get; set; }

Property Value

Action<RecordMetadata, JVMBridgeException>

Remarks

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

OnOnSend

public Func<ProducerRecord, ProducerRecord> OnOnSend { get; set; }

Property Value

Func<ProducerRecord, ProducerRecord>

Remarks

If OnOnSend 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 ProducerInterceptor

protected virtual void InitializeHandlers()

OnAcknowledgement(RecordMetadata, JVMBridgeException)

public virtual void OnAcknowledgement(RecordMetadata arg0, JVMBridgeException arg1)

Parameters

arg0 RecordMetadata

RecordMetadata

arg1 JVMBridgeException

Exception

Remarks

The method invokes the default implementation in the JVM interface using OnAcknowledgementDefault(RecordMetadata, JVMBridgeException, Headers); override the method to implement a different behavior

OnAcknowledgement(RecordMetadata, JVMBridgeException, Headers)

public virtual void OnAcknowledgement(RecordMetadata arg0, JVMBridgeException arg1, Headers arg2)

Parameters

arg0 RecordMetadata

RecordMetadata

arg1 JVMBridgeException

Exception

arg2 Headers

Headers

Remarks

The method invokes the default implementation in the JVM interface using OnAcknowledgementDefault(RecordMetadata, JVMBridgeException, Headers); override the method to implement a different behavior

OnAcknowledgementDefault(RecordMetadata, JVMBridgeException)

public void OnAcknowledgementDefault(RecordMetadata arg0, JVMBridgeException arg1)

Parameters

arg0 RecordMetadata

RecordMetadata

arg1 JVMBridgeException

Exception

Remarks

The method invokes the default implementation in the JVM interface

OnAcknowledgementDefault(RecordMetadata, JVMBridgeException, Headers)

public void OnAcknowledgementDefault(RecordMetadata arg0, JVMBridgeException arg1, Headers arg2)

Parameters

arg0 RecordMetadata

RecordMetadata

arg1 JVMBridgeException

Exception

arg2 Headers

Headers

Remarks

The method invokes the default implementation in the JVM interface

OnSend(ProducerRecord)

public virtual ProducerRecord OnSend(ProducerRecord arg0)

Parameters

arg0 ProducerRecord

ProducerRecord

Returns

ProducerRecord

ProducerRecord