Class OffsetSync

Namespace

Org.Apache.Kafka.Connect.Mirror

Assembly

MASES.KNet.dll

https://www.javadoc.io/doc/org.apache.kafka/connect-mirror/4.2.1/org/apache/kafka/connect/mirror/OffsetSync.html

public class OffsetSync : Record, IDynamicMetaObjectProvider, IJVMBridgeCore, IEquatable<IJVMBridgeBaseInstance>, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeBaseInstance, IJVMBridgeDefinition

Inheritance

object

DynamicObject

JVMBridgeBase

JVMBridgeBase<Record>

Record

OffsetSync

Implements

IDynamicMetaObjectProvider

IJVMBridgeCore

IEquatable<IJVMBridgeBaseInstance>

IDisposable

IJVMBridgeBaseStatic

IJVMBridgeBase

IJVMBridgeBaseInstance

IJVMBridgeDefinition

Constructors

OffsetSync(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 OffsetSync(IJVMBridgeBaseInitializer initializer)

Parameters

initializer IJVMBridgeBaseInitializer

OffsetSync(TopicPartition, long, long)

https://www.javadoc.io/doc/org.apache.kafka/connect-mirror/4.2.1/org/apache/kafka/connect/mirror/OffsetSync.html#%3Cinit%3E(org.apache.kafka.common.TopicPartition,long,long)

public OffsetSync(TopicPartition topicPartition, long upstreamOffset, long downstreamOffset)

Parameters

topicPartition TopicPartition

TopicPartition

upstreamOffset long

long

downstreamOffset long

long

Properties

BridgeClassName

Java class name to be instantiated

public override string BridgeClassName { get; }

Property Value

string

DOWNSTREAM_OFFSET_KEY

https://www.javadoc.io/doc/org.apache.kafka/connect-mirror/4.2.1/org/apache/kafka/connect/mirror/OffsetSync.html#DOWNSTREAM_OFFSET_KEY

public static String DOWNSTREAM_OFFSET_KEY { get; set; }

Property Value

String

IsBridgeAbstract

true if the BridgeClassName is an abstract class, i.e. cannot be created an instance

public override bool IsBridgeAbstract { get; }

Property Value

bool

IsBridgeCloseable

true if the BridgeClassName implements java.lang.AutoCloseable

public override bool IsBridgeCloseable { get; }

Property Value

bool

IsBridgeInterface

true if the BridgeClassName is an interface, i.e. does not have any public constructor

public override bool IsBridgeInterface { get; }

Property Value

bool

IsBridgeStatic

true if the BridgeClassName is a static class, i.e. does not have any public constructor

public override bool IsBridgeStatic { get; }

Property Value

bool

PARTITION_KEY

https://www.javadoc.io/doc/org.apache.kafka/connect-mirror/4.2.1/org/apache/kafka/connect/mirror/OffsetSync.html#PARTITION_KEY

public static String PARTITION_KEY { get; set; }

Property Value

String

TOPIC_KEY

https://www.javadoc.io/doc/org.apache.kafka/connect-mirror/4.2.1/org/apache/kafka/connect/mirror/OffsetSync.html#TOPIC_KEY

public static String TOPIC_KEY { get; set; }

Property Value

String

UPSTREAM_OFFSET_KEY

https://www.javadoc.io/doc/org.apache.kafka/connect-mirror/4.2.1/org/apache/kafka/connect/mirror/OffsetSync.html#UPSTREAM_OFFSET_KEY

public static String UPSTREAM_OFFSET_KEY { get; set; }

Property Value

String

Methods

CreatePoolableInstance(TopicPartition, long, long)

HPA initializer for OffsetSync(Org.Apache.Kafka.Common.TopicPartition topicPartition, long upstreamOffset, long downstreamOffset)

public static OffsetSync CreatePoolableInstance(TopicPartition topicPartition, long upstreamOffset, long downstreamOffset)

Parameters

topicPartition TopicPartition

upstreamOffset long

downstreamOffset long

Returns

OffsetSync

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

https://www.javadoc.io/doc/org.apache.kafka/connect-mirror/4.2.1/org/apache/kafka/connect/mirror/OffsetSync.html#deserializeRecord(org.apache.kafka.clients.consumer.ConsumerRecord)

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

Parameters

arg0 ConsumerRecord<byte[], byte[]>

ConsumerRecord

Returns

OffsetSync

OffsetSync

DownstreamOffset()

https://www.javadoc.io/doc/org.apache.kafka/connect-mirror/4.2.1/org/apache/kafka/connect/mirror/OffsetSync.html#downstreamOffset()

public long DownstreamOffset()

Returns

long

long

TopicPartition()

https://www.javadoc.io/doc/org.apache.kafka/connect-mirror/4.2.1/org/apache/kafka/connect/mirror/OffsetSync.html#topicPartition()

public TopicPartition TopicPartition()

Returns

TopicPartition

TopicPartition

UpstreamOffset()

https://www.javadoc.io/doc/org.apache.kafka/connect-mirror/4.2.1/org/apache/kafka/connect/mirror/OffsetSync.html#upstreamOffset()

public long UpstreamOffset()

Returns

long

long