Class TransactionDescription
public class TransactionDescription : JVMBridgeBase<TransactionDescription>, IDynamicMetaObjectProvider, IJVMBridgeCore, IEquatable<IJVMBridgeBaseInstance>, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeBaseInstance, IJVMBridgeDefinition
- Inheritance
-
TransactionDescription
- Implements
Constructors
TransactionDescription(IJVMBridgeBaseInitializer)
Initializer used internally by JCOBridge. Do not use directly.
[Obsolete("This public initializer is needed for JCOBridge internal use, other uses can produce unidentible behaviors.")]
public TransactionDescription(IJVMBridgeBaseInitializer initializer)
Parameters
initializerIJVMBridgeBaseInitializer
TransactionDescription(int, TransactionState, long, int, long, OptionalLong, Set<TopicPartition>)
public TransactionDescription(int arg0, TransactionState arg1, long arg2, int arg3, long arg4, OptionalLong arg5, Set<TopicPartition> arg6)
Parameters
arg0intarg1TransactionStatearg2longarg3intarg4longarg5OptionalLongarg6Set<TopicPartition>
Properties
BridgeClassName
Java class name to be instantiated
public override string BridgeClassName { get; }
Property Value
IsBridgeAbstract
true if the BridgeClassName is an abstract class, i.e. cannot be created an instance
public override bool IsBridgeAbstract { get; }
Property Value
IsBridgeCloseable
true if the BridgeClassName implements java.lang.AutoCloseable
public override bool IsBridgeCloseable { get; }
Property Value
IsBridgeInterface
true if the BridgeClassName is an interface, i.e. does not have any public constructor
public override bool IsBridgeInterface { get; }
Property Value
IsBridgeStatic
true if the BridgeClassName is a static class, i.e. does not have any public constructor
public override bool IsBridgeStatic { get; }
Property Value
Methods
CoordinatorId()
public int CoordinatorId()
Returns
CreatePoolableInstance(int, TransactionState, long, int, long, OptionalLong, Set<TopicPartition>)
HPA initializer for TransactionDescription(int arg0, Org.Apache.Kafka.Clients.Admin.TransactionState arg1, long arg2, int arg3, long arg4, Java.Util.OptionalLong arg5, Java.Util.Set%3COrg.Apache.Kafka.Common.TopicPartition%3E arg6)
public static TransactionDescription CreatePoolableInstance(int arg0, TransactionState arg1, long arg2, int arg3, long arg4, OptionalLong arg5, Set<TopicPartition> arg6)
Parameters
arg0intarg1TransactionStatearg2longarg3intarg4longarg5OptionalLongarg6Set<TopicPartition>
Returns
ProducerEpoch()
public int ProducerEpoch()
Returns
ProducerId()
public long ProducerId()
Returns
State()
public TransactionState State()
Returns
TopicPartitions()
public Set<TopicPartition> TopicPartitions()
Returns
TransactionStartTimeMs()
public OptionalLong TransactionStartTimeMs()
Returns
TransactionTimeoutMs()
public long TransactionTimeoutMs()