org.apache.kafka.connect.sink

Class SinkRecord

java.lang.Object

org.apache.kafka.connect.connector.ConnectRecord

org.apache.kafka.connect.sink.SinkRecord

@InterfaceStability.Unstable
public class SinkRecord
extends ConnectRecord

SinkRecord is a ConnectRecord that has been read from Kafka and includes the kafkaOffset of the record in the Kafka topic-partition in addition to the standard fields. This information should be used by the SinkTask to coordinate kafkaOffset commits. It also includes the TimestampType, which may be TimestampType.NO_TIMESTAMP_TYPE, and the relevant timestamp, which may be null.

Constructor Summary

Constructors

Constructor and Description
SinkRecord(String topic, int partition, Schema keySchema, Object key, Schema valueSchema, Object value, long kafkaOffset)
SinkRecord(String topic, int partition, Schema keySchema, Object key, Schema valueSchema, Object value, long kafkaOffset, Long timestamp, org.apache.kafka.common.record.TimestampType timestampType)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	equals(Object o)
int	hashCode()
long	kafkaOffset()
org.apache.kafka.common.record.TimestampType	timestampType()
String	toString()

Methods inherited from class org.apache.kafka.connect.connector.ConnectRecord

kafkaPartition, key, keySchema, timestamp, topic, value, valueSchema

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

SinkRecord

public SinkRecord(String topic,
          int partition,
          Schema keySchema,
          Object key,
          Schema valueSchema,
          Object value,
          long kafkaOffset)

SinkRecord

public SinkRecord(String topic,
          int partition,
          Schema keySchema,
          Object key,
          Schema valueSchema,
          Object value,
          long kafkaOffset,
          Long timestamp,
          org.apache.kafka.common.record.TimestampType timestampType)

Method Detail

kafkaOffset

public long kafkaOffset()

timestampType

public org.apache.kafka.common.record.TimestampType timestampType()

equals

public boolean equals(Object o)

Overrides:

equals in class ConnectRecord

hashCode

public int hashCode()

Overrides:

hashCode in class ConnectRecord

toString

public String toString()

Overrides:

toString in class ConnectRecord