Class Checkpoint
public class Checkpoint : JVMBridgeBase<Checkpoint>, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition- Inheritance
-
JVMBridgeBaseJVMBridgeBase<Checkpoint>Checkpoint
- Implements
-
IJVMBridgeCoreIJVMBridgeBaseStaticIJVMBridgeBaseIJVMBridgeDefinition
- Inherited Members
-
JVMBridgeBase<Checkpoint>.SExecuteWithSignature<TReturn>(IJavaType, string, string, params object[])JVMBridgeBase<Checkpoint>.SExecuteWithSignature<TNewClass, TReturn>(string, string, params object[])JVMBridgeBase<Checkpoint>.IsAssignableFrom(IJavaType)JVMBridgeBase<Checkpoint>.IsAssignableFrom<T>()JVMBridgeBase<Checkpoint>.Execute<T>(params T[])JVMBridgeBase<Checkpoint>.DynBridgeClazzJVMBridgeBase<Checkpoint>.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
Checkpoint()
Default constructor: even if the corresponding Java class does not have one, it is mandatory for JCOBridge
public Checkpoint()Checkpoint(String, TopicPartition, long, long, String)
public Checkpoint(String arg0, TopicPartition arg1, long arg2, long arg3, String arg4)Parameters
arg0Stringarg1TopicPartitionarg2longarg3longarg4String
Checkpoint(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 Checkpoint(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
CONSUMER_GROUP_ID_KEY
public static String CONSUMER_GROUP_ID_KEY { get; }Property Value
DOWNSTREAM_OFFSET_KEY
public static String DOWNSTREAM_OFFSET_KEY { 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
METADATA_KEY
public static String METADATA_KEY { get; }Property Value
PARTITION_KEY
public static String PARTITION_KEY { get; }Property Value
TOPIC_KEY
public static String TOPIC_KEY { get; }Property Value
UPSTREAM_OFFSET_KEY
public static String UPSTREAM_OFFSET_KEY { get; }Property Value
VERSION
public static short VERSION { get; }Property Value
VERSION_KEY
public static String VERSION_KEY { get; }Property Value
Methods
ConsumerGroupId()
public String ConsumerGroupId()Returns
DeserializeRecord(ConsumerRecord<byte[], byte[]>)
public static Checkpoint DeserializeRecord(ConsumerRecord<byte[], byte[]> arg0)Parameters
arg0ConsumerRecord<byte[], byte[]>
Returns
DownstreamOffset()
public long DownstreamOffset()Returns
Metadata()
public String Metadata()Returns
OffsetAndMetadata()
public OffsetAndMetadata OffsetAndMetadata()Returns
TopicPartition()
public TopicPartition TopicPartition()Returns
UpstreamOffset()
public long UpstreamOffset()