org.apache.kafka.connect.mirror

Class Checkpoint

java.lang.Object

org.apache.kafka.connect.mirror.Checkpoint

public class Checkpoint
extends Object

Checkpoint records emitted from MirrorCheckpointConnector. Encodes remote consumer group state.

Field Summary

Fields

Modifier and Type	Field and Description
static String	CONSUMER_GROUP_ID_KEY
static String	DOWNSTREAM_OFFSET_KEY
static org.apache.kafka.common.protocol.types.Schema	HEADER_SCHEMA
static org.apache.kafka.common.protocol.types.Schema	KEY_SCHEMA
static String	METADATA_KEY
static String	PARTITION_KEY
static String	TOPIC_KEY
static String	UPSTREAM_OFFSET_KEY
static org.apache.kafka.common.protocol.types.Schema	VALUE_SCHEMA_V0
static short	VERSION
static String	VERSION_KEY

Constructor Summary

Constructors

Constructor and Description
Checkpoint(String consumerGroupId, TopicPartition topicPartition, long upstreamOffset, long downstreamOffset, String metadata)

Method Summary

Modifier and Type	Method and Description
String	consumerGroupId()
static Checkpoint	deserializeRecord(ConsumerRecord<byte[],byte[]> record)
long	downstreamOffset()
String	metadata()
OffsetAndMetadata	offsetAndMetadata()
TopicPartition	topicPartition()
String	toString()
long	upstreamOffset()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

TOPIC_KEY

public static final String TOPIC_KEY

See Also:

Constant Field Values

PARTITION_KEY

public static final String PARTITION_KEY

See Also:

Constant Field Values

CONSUMER_GROUP_ID_KEY

public static final String CONSUMER_GROUP_ID_KEY

See Also:

Constant Field Values

UPSTREAM_OFFSET_KEY

public static final String UPSTREAM_OFFSET_KEY

See Also:

Constant Field Values

DOWNSTREAM_OFFSET_KEY

public static final String DOWNSTREAM_OFFSET_KEY

See Also:

Constant Field Values

METADATA_KEY

public static final String METADATA_KEY

See Also:

Constant Field Values

VERSION_KEY

public static final String VERSION_KEY

See Also:

Constant Field Values

VERSION

public static final short VERSION

See Also:

Constant Field Values

VALUE_SCHEMA_V0

public static final org.apache.kafka.common.protocol.types.Schema VALUE_SCHEMA_V0

KEY_SCHEMA

public static final org.apache.kafka.common.protocol.types.Schema KEY_SCHEMA

HEADER_SCHEMA

public static final org.apache.kafka.common.protocol.types.Schema HEADER_SCHEMA

Constructor Detail

Checkpoint

public Checkpoint(String consumerGroupId,
                  TopicPartition topicPartition,
                  long upstreamOffset,
                  long downstreamOffset,
                  String metadata)

Method Detail

consumerGroupId

public String consumerGroupId()

topicPartition

public TopicPartition topicPartition()

upstreamOffset

public long upstreamOffset()

downstreamOffset

public long downstreamOffset()

metadata

public String metadata()

offsetAndMetadata

public OffsetAndMetadata offsetAndMetadata()

toString

public String toString()

Overrides:

toString in class Object

deserializeRecord

public static Checkpoint deserializeRecord(ConsumerRecord<byte[],byte[]> record)