Table of Contents

Class Checkpoint

Namespace
Org.Apache.Kafka.Connect.Mirror
Assembly
MASES.KNet.dll

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

public class Checkpoint : JVMBridgeBase<Checkpoint>, IDynamicMetaObjectProvider, IJVMBridgeCore, IEquatable<IJVMBridgeBaseInstance>, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeBaseInstance, IJVMBridgeDefinition
Inheritance
Checkpoint
Implements

Constructors

Checkpoint(String, TopicPartition, long, long, String)

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

public Checkpoint(String arg0, TopicPartition arg1, long arg2, long arg3, String arg4)

Parameters

arg0 String

String

arg1 TopicPartition

TopicPartition

arg2 long

long

arg3 long

long

arg4 String

String

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

Parameters

initializer IJVMBridgeBaseInitializer

Properties

BridgeClassName

Java class name to be instantiated

public override string BridgeClassName { get; }

Property Value

string

CONSUMER_GROUP_ID_KEY

https://www.javadoc.io/doc/org.apache.kafka/connect-mirror-client/4.2.1/org/apache/kafka/connect/mirror/Checkpoint.html#CONSUMER_GROUP_ID_KEY

public static String CONSUMER_GROUP_ID_KEY { get; set; }

Property Value

String

DOWNSTREAM_OFFSET_KEY

https://www.javadoc.io/doc/org.apache.kafka/connect-mirror-client/4.2.1/org/apache/kafka/connect/mirror/Checkpoint.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

METADATA_KEY

https://www.javadoc.io/doc/org.apache.kafka/connect-mirror-client/4.2.1/org/apache/kafka/connect/mirror/Checkpoint.html#METADATA_KEY

public static String METADATA_KEY { get; set; }

Property Value

String

PARTITION_KEY

https://www.javadoc.io/doc/org.apache.kafka/connect-mirror-client/4.2.1/org/apache/kafka/connect/mirror/Checkpoint.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-client/4.2.1/org/apache/kafka/connect/mirror/Checkpoint.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-client/4.2.1/org/apache/kafka/connect/mirror/Checkpoint.html#UPSTREAM_OFFSET_KEY

public static String UPSTREAM_OFFSET_KEY { get; set; }

Property Value

String

VERSION

https://www.javadoc.io/doc/org.apache.kafka/connect-mirror-client/4.2.1/org/apache/kafka/connect/mirror/Checkpoint.html#VERSION

public static short VERSION { get; set; }

Property Value

short

VERSION_KEY

https://www.javadoc.io/doc/org.apache.kafka/connect-mirror-client/4.2.1/org/apache/kafka/connect/mirror/Checkpoint.html#VERSION_KEY

public static String VERSION_KEY { get; set; }

Property Value

String

Methods

ConsumerGroupId()

https://www.javadoc.io/doc/org.apache.kafka/connect-mirror-client/4.2.1/org/apache/kafka/connect/mirror/Checkpoint.html#consumerGroupId()

public String ConsumerGroupId()

Returns

String

String

CreatePoolableInstance(String, TopicPartition, long, long, String)

HPA initializer for Checkpoint(Java.Lang.String arg0, Org.Apache.Kafka.Common.TopicPartition arg1, long arg2, long arg3, Java.Lang.String arg4)

public static Checkpoint CreatePoolableInstance(String arg0, TopicPartition arg1, long arg2, long arg3, String arg4)

Parameters

arg0 String
arg1 TopicPartition
arg2 long
arg3 long
arg4 String

Returns

Checkpoint

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

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

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

Parameters

arg0 ConsumerRecord<byte[], byte[]>

ConsumerRecord

Returns

Checkpoint

Checkpoint

DownstreamOffset()

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

public long DownstreamOffset()

Returns

long

long

Metadata()

https://www.javadoc.io/doc/org.apache.kafka/connect-mirror-client/4.2.1/org/apache/kafka/connect/mirror/Checkpoint.html#metadata()

public String Metadata()

Returns

String

String

OffsetAndMetadata()

https://www.javadoc.io/doc/org.apache.kafka/connect-mirror-client/4.2.1/org/apache/kafka/connect/mirror/Checkpoint.html#offsetAndMetadata()

public OffsetAndMetadata OffsetAndMetadata()

Returns

OffsetAndMetadata

OffsetAndMetadata

TopicPartition()

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

public TopicPartition TopicPartition()

Returns

TopicPartition

TopicPartition

UpstreamOffset()

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

public long UpstreamOffset()

Returns

long

long

Edit this page