Table of Contents

Class Producer

Namespace
Org.Apache.Kafka.Clients.Producer
Assembly
MASES.KNet.dll
public class Producer : Closeable, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition, ICloseable, IAutoCloseable
Inheritance
JVMBridgeBase
JVMBridgeBase<AutoCloseable>
Producer
Implements
IJVMBridgeCore
IJVMBridgeBaseStatic
IJVMBridgeBase
IJVMBridgeDefinition
Derived
Inherited Members
JVMBridgeBase<AutoCloseable>.IsAssignableFrom(IJavaType)
JVMBridgeBase<AutoCloseable>.IsAssignableFrom<T>()
JVMBridgeBase<AutoCloseable>.Execute<T>(params T[])
JVMBridgeBase<AutoCloseable>.DynBridgeClazz
JVMBridgeBase<AutoCloseable>.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.Dispose()
JVMBridgeBase.ToString()
JVMBridgeBase.GetHashCode()
JVMBridgeBase.Notify()
JVMBridgeBase.NotifyAll()
JVMBridgeBase.Wait()
JVMBridgeBase.DynBridgeInstance
JVMBridgeBase.BridgeInstance
JVMBridgeBase.IsBridgeListener

Constructors

Producer()

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

[Obsolete("Producer class represents, in .NET, an instance of a JVM interface or abstract class. This public initializer is needed for JCOBridge internal use, other uses can produce unidentible behaviors.")]
public Producer()

Producer(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

[Obsolete("Producer class represents, in .NET, an instance of a JVM interface or abstract class. This public initializer is needed for JCOBridge internal use, other uses can produce unidentible behaviors.")]
public Producer(params object[] args)

Parameters

args object[]

Properties

BridgeClassName

public override string BridgeClassName { get; }

Property Value

string

IsBridgeAbstract

public override bool IsBridgeAbstract { get; }

Property Value

bool

IsBridgeCloseable

public override bool IsBridgeCloseable { get; }

Property Value

bool

IsBridgeInterface

public override bool IsBridgeInterface { get; }

Property Value

bool

IsBridgeStatic

public override bool IsBridgeStatic { get; }

Property Value

bool

Methods

AbortTransaction()

public void AbortTransaction()

Exceptions

ProducerFencedException

BeginTransaction()

public void BeginTransaction()

Exceptions

ProducerFencedException

ClientInstanceId(Duration)

public Uuid ClientInstanceId(Duration arg0)

Parameters

arg0 Duration

Duration

Returns

Uuid

Uuid

Close()

public void Close()

Close(Duration)

public void Close(Duration arg0)

Parameters

arg0 Duration

Duration

CommitTransaction()

public void CommitTransaction()

Exceptions

ProducerFencedException

Flush()

public void Flush()

InitTransactions()

public void InitTransactions()

Metrics()

public Map Metrics()

Returns

Map

Map

PartitionsFor(String)

public List PartitionsFor(String arg0)

Parameters

arg0 String

String

Returns

List

List

Send(ProducerRecord)

public Future Send(ProducerRecord arg0)

Parameters

arg0 ProducerRecord

ProducerRecord

Returns

Future

Future

Send(ProducerRecord, Callback)

public Future Send(ProducerRecord arg0, Callback arg1)

Parameters

arg0 ProducerRecord

ProducerRecord

arg1 Callback

Callback

Returns

Future

Future

SendOffsetsToTransaction(Map, ConsumerGroupMetadata)

public void SendOffsetsToTransaction(Map arg0, ConsumerGroupMetadata arg1)

Parameters

arg0 Map

Map

arg1 ConsumerGroupMetadata

ConsumerGroupMetadata

Exceptions

ProducerFencedException