Table of Contents

Class OffsetSync

Namespace
Org.Apache.Kafka.Connect.Mirror
Assembly
MASES.KNet.dll
public class OffsetSync : JVMBridgeBase<OffsetSync>, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition
Inheritance
JVMBridgeBase
JVMBridgeBase<OffsetSync>
OffsetSync
Implements
IJVMBridgeCore
IJVMBridgeBaseStatic
IJVMBridgeBase
IJVMBridgeDefinition
Inherited Members
JVMBridgeBase<OffsetSync>.IsAssignableFrom(IJavaType)
JVMBridgeBase<OffsetSync>.IsAssignableFrom<T>()
JVMBridgeBase<OffsetSync>.Execute<T>(params T[])
JVMBridgeBase<OffsetSync>.DynBridgeClazz
JVMBridgeBase<OffsetSync>.BridgeClazz
JVMBridgeBase.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.DynBridgeInstance
JVMBridgeBase.BridgeInstance
JVMBridgeBase.IsBridgeListener

Constructors

OffsetSync()

Default constructor: even if the corresponding Java class does not have one, it is mandatory for JCOBridge

public OffsetSync()

OffsetSync(TopicPartition, long, long)

public OffsetSync(TopicPartition arg0, long arg1, long arg2)

Parameters

arg0 TopicPartition

TopicPartition

arg1 long

long

arg2 long

long

OffsetSync(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 OffsetSync(params object[] args)

Parameters

args object[]

Properties

BridgeClassName

public override string BridgeClassName { get; }

Property Value

string

DOWNSTREAM_OFFSET_KEY

public static String DOWNSTREAM_OFFSET_KEY { get; }

Property Value

String

IsBridgeAbstract

public override bool IsBridgeAbstract { get; }

Property Value

bool

IsBridgeCloseable

public override bool IsBridgeCloseable { get; }

Property Value

bool

IsBridgeInterface

public override bool IsBridgeInterface { get; }

Property Value

bool

IsBridgeStatic

public override bool IsBridgeStatic { get; }

Property Value

bool

PARTITION_KEY

public static String PARTITION_KEY { get; }

Property Value

String

TOPIC_KEY

public static String TOPIC_KEY { get; }

Property Value

String

UPSTREAM_OFFSET_KEY

public static String UPSTREAM_OFFSET_KEY { get; }

Property Value

String

Methods

DeserializeRecord(ConsumerRecord<byte[], byte[]>)

public static OffsetSync DeserializeRecord(ConsumerRecord<byte[], byte[]> arg0)

Parameters

arg0 ConsumerRecord<byte[], byte[]>

ConsumerRecord

Returns

OffsetSync

OffsetSync

DownstreamOffset()

public long DownstreamOffset()

Returns

long

long

TopicPartition()

public TopicPartition TopicPartition()

Returns

TopicPartition

TopicPartition

UpstreamOffset()

public long UpstreamOffset()

Returns

long

long