Class KafkaRaftClient
public class KafkaRaftClient : RaftClient, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition, IAutoCloseable- Inheritance
-
JVMBridgeBaseJVMBridgeBase<AutoCloseable>KafkaRaftClient
- 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
KafkaRaftClient()
Default constructor: even if the corresponding Java class does not have one, it is mandatory for JCOBridge
public KafkaRaftClient()KafkaRaftClient(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 KafkaRaftClient(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
MAX_BATCH_SIZE_BYTES
public static int MAX_BATCH_SIZE_BYTES { get; }Property Value
MAX_FETCH_SIZE_BYTES
public static int MAX_FETCH_SIZE_BYTES { get; }Property Value
MAX_FETCH_WAIT_MS
public static int MAX_FETCH_WAIT_MS { get; }Property Value
Methods
Close()
public void Close()CreateSnapshot(OffsetAndEpoch, long)
public Optional CreateSnapshot(OffsetAndEpoch arg0, long arg1)Parameters
arg0OffsetAndEpocharg1long
Returns
Handle(Inbound)
public void Handle(RaftRequest.Inbound arg0)Parameters
HighWatermark()
public OptionalLong HighWatermark()Returns
Initialize(Map, QuorumStateStore, Metrics)
public void Initialize(Map arg0, QuorumStateStore arg1, Metrics arg2)Parameters
arg0Maparg1QuorumStateStorearg2Metrics
IsRunning()
public bool IsRunning()Returns
IsShuttingDown()
public bool IsShuttingDown()Returns
LatestSnapshotId()
public Optional LatestSnapshotId()Returns
LeaderAndEpoch()
public LeaderAndEpoch LeaderAndEpoch()Returns
LogEndOffset()
public long LogEndOffset()Returns
NodeId()
public OptionalInt NodeId()Returns
Poll()
public void Poll()PrepareAppend(int, List)
public long PrepareAppend(int arg0, List arg1)Parameters
Returns
Register(Listener)
public void Register(RaftClient.Listener arg0)Parameters
Resign(int)
public void Resign(int arg0)Parameters
SchedulePreparedAppend()
public void SchedulePreparedAppend()Shutdown(int)
public CompletableFuture Shutdown(int arg0)Parameters
Returns
Unregister(Listener)
public void Unregister(RaftClient.Listener arg0)