Class KafkaProducer
public class KafkaProducer : Producer, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition, ICloseable, IAutoCloseable- Inheritance
-
JVMBridgeBaseJVMBridgeBase<AutoCloseable>KafkaProducer
- Implements
-
IJVMBridgeCoreIJVMBridgeBaseStaticIJVMBridgeBaseIJVMBridgeDefinition
- Inherited Members
-
JVMBridgeBase<AutoCloseable>.SExecuteWithSignature(Type, IJavaType, string, string, params object[])JVMBridgeBase<AutoCloseable>.SExecute<TReturn, TConverter>(Type, IJavaType, string, params object[])JVMBridgeBase<AutoCloseable>.IsAssignableFrom(IJavaType)JVMBridgeBase<AutoCloseable>.IsAssignableFrom<T>()JVMBridgeBase<AutoCloseable>.Execute<T>(params T[])JVMBridgeBase<AutoCloseable>.DynBridgeClazzJVMBridgeBase<AutoCloseable>.BridgeClazzJVMBridgeBase.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.IExecuteWithSignature<TNewClass, TReturn, TConverter>(string, string, params object[])JVMBridgeBase.DynBridgeInstanceJVMBridgeBase.BridgeInstanceJVMBridgeBase.IsBridgeListener
Constructors
KafkaProducer()
Default constructor: even if the corresponding Java class does not have one, it is mandatory for JCOBridge
public KafkaProducer()KafkaProducer(Map)
public KafkaProducer(Map arg0)Parameters
KafkaProducer(Map, Serializer, Serializer)
public KafkaProducer(Map arg0, Serializer arg1, Serializer arg2)Parameters
arg0Maparg1Serializerarg2Serializer
KafkaProducer(Properties)
public KafkaProducer(Properties arg0)Parameters
arg0Properties
KafkaProducer(Properties, Serializer, Serializer)
public KafkaProducer(Properties arg0, Serializer arg1, Serializer arg2)Parameters
arg0Propertiesarg1Serializerarg2Serializer
KafkaProducer(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 KafkaProducer(params object[] args)Parameters
argsobject[]
Properties
BridgeClassName
https://www.jcobridge.com/api-clr/html/P_MASES_JCOBridge_C2JBridge_JVMBridgeBase_BridgeClassName.htm
public override string BridgeClassName { get; }Property Value
IsBridgeAbstract
public override bool IsBridgeAbstract { get; }Property Value
IsBridgeCloseable
public override bool IsBridgeCloseable { get; }Property Value
IsBridgeInterface
public override bool IsBridgeInterface { get; }Property Value
IsBridgeStatic
public override bool IsBridgeStatic { get; }Property Value
NETWORK_THREAD_PREFIX
public static String NETWORK_THREAD_PREFIX { get; }Property Value
PRODUCER_METRIC_GROUP_NAME
public static String PRODUCER_METRIC_GROUP_NAME { get; }Property Value
Methods
AbortTransaction()
public void AbortTransaction()Exceptions
BeginTransaction()
public void BeginTransaction()Exceptions
ClientInstanceId(Duration)
public Uuid ClientInstanceId(Duration arg0)Parameters
Returns
Close()
public void Close()Close(Duration)
public void Close(Duration arg0)Parameters
CommitTransaction()
public void CommitTransaction()Exceptions
Flush()
public void Flush()InitTransactions()
public void InitTransactions()Metrics()
public Map Metrics()Returns
PartitionsFor(String)
public List PartitionsFor(String arg0)Parameters
Returns
Send(ProducerRecord)
public Future Send(ProducerRecord arg0)Parameters
Returns
Send(ProducerRecord, Callback)
public Future Send(ProducerRecord arg0, Callback arg1)Parameters
arg0ProducerRecordarg1Callback
Returns
SendOffsetsToTransaction(Map, ConsumerGroupMetadata)
public void SendOffsetsToTransaction(Map arg0, ConsumerGroupMetadata arg1)Parameters
arg0Maparg1ConsumerGroupMetadata