Class KafkaRaftClient<T>
public class KafkaRaftClient<T> : RaftClient<T>, IDynamicMetaObjectProvider, IJVMBridgeCore, IEquatable<IJVMBridgeBase>, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition, IRaftClient<T>, IAutoCloseable
Type Parameters
T
- Inheritance
-
RaftClient<T>KafkaRaftClient<T>
- Implements
-
IRaftClient<T>
- Inherited Members
-
JVMBridgeBase<AutoCloseable>.SExecuteWithSignature(Type, IJavaType, string, string, params object[])JVMBridgeBase<AutoCloseable>.SExecute<TReturn, TConverter>(Type, IJavaType, string, params object[])JVMBridgeBase<AutoCloseable>.SExecuteWithSignatureArray<TArrayType>(string, string, params object[])
Constructors
KafkaRaftClient()
Default constructor: even if the corresponding Java class does not have one, it is mandatory for JCOBridge
public KafkaRaftClient()
KafkaRaftClient(IJVMBridgeBaseInitializer)
Internal constructor: used internally from JCOBridge
[Obsolete("This public initializer is needed for JCOBridge internal use, other uses can produce unidentible behaviors.")]
public KafkaRaftClient(IJVMBridgeBaseInitializer initializer)
Parameters
initializer
IJVMBridgeBaseInitializer
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
args
object[]
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 Closeable
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
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()
Handle(Inbound)
public void Handle(RaftRequest.Inbound arg0)
Parameters
HighWatermark()
public OptionalLong HighWatermark()
Returns
Initialize(Map<Integer, InetSocketAddress>, QuorumStateStore, Metrics, ExternalKRaftMetrics)
public void Initialize(Map<Integer, InetSocketAddress> arg0, QuorumStateStore arg1, Metrics arg2, ExternalKRaftMetrics arg3)
Parameters
arg0
Map<Integer, InetSocketAddress>arg1
QuorumStateStorearg2
Metricsarg3
ExternalKRaftMetrics
IsRunning()
public bool IsRunning()
Returns
IsShuttingDown()
public bool IsShuttingDown()
Returns
LeaderAndEpoch()
public LeaderAndEpoch LeaderAndEpoch()
Returns
LogEndOffset()
public long LogEndOffset()
Returns
NodeId()
public OptionalInt NodeId()
Returns
Poll()
public void Poll()
PrepareAppend(int, List<T>)
public long PrepareAppend(int arg0, List<T> arg1)
Parameters
Returns
Register(Listener<T>)
public void Register(RaftClient.Listener<T> arg0)
Parameters
arg0
RaftClient.Listener<T>
Resign(int)
public void Resign(int arg0)
Parameters
SchedulePreparedAppend()
public void SchedulePreparedAppend()
Shutdown(int)
public CompletableFuture<Void> Shutdown(int arg0)
Parameters
Returns
Unregister(Listener<T>)
public void Unregister(RaftClient.Listener<T> arg0)
Parameters
arg0
RaftClient.Listener<T>
Operators
implicit operator KafkaRaftClient(KafkaRaftClient<T>)
Converter from KafkaRaftClient<T> to KafkaRaftClient
public static implicit operator KafkaRaftClient(KafkaRaftClient<T> t)
Parameters
t
KafkaRaftClient<T>