org.apache.kafka.connect.source

Class SourceRecord

java.lang.Object

org.apache.kafka.connect.connector.ConnectRecord<SourceRecord>

org.apache.kafka.connect.source.SourceRecord

public class SourceRecord
extends ConnectRecord<SourceRecord>

SourceRecords are generated by SourceTasks and passed to Kafka Connect for storage in Kafka. In addition to the standard fields in ConnectRecord which specify where data is stored in Kafka, they also include a sourcePartition and sourceOffset.

The sourcePartition represents a single input sourcePartition that the record came from (e.g. a filename, table name, or topic-partition). The sourceOffset represents a position in that sourcePartition which can be used to resume consumption of data.

These values can have arbitrary structure and should be represented using org.apache.kafka.connect.data objects (or primitive values). For example, a database connector might specify the sourcePartition as a record containing { "db": "database_name", "table": "table_name"} and the sourceOffset as a Long containing the timestamp of the row.

Constructor Summary

Constructors

Constructor and Description
SourceRecord(java.util.Map<java.lang.String,?> sourcePartition, java.util.Map<java.lang.String,?> sourceOffset, java.lang.String topic, java.lang.Integer partition, Schema valueSchema, java.lang.Object value)
SourceRecord(java.util.Map<java.lang.String,?> sourcePartition, java.util.Map<java.lang.String,?> sourceOffset, java.lang.String topic, java.lang.Integer partition, Schema keySchema, java.lang.Object key, Schema valueSchema, java.lang.Object value)
SourceRecord(java.util.Map<java.lang.String,?> sourcePartition, java.util.Map<java.lang.String,?> sourceOffset, java.lang.String topic, java.lang.Integer partition, Schema keySchema, java.lang.Object key, Schema valueSchema, java.lang.Object value, java.lang.Long timestamp)
SourceRecord(java.util.Map<java.lang.String,?> sourcePartition, java.util.Map<java.lang.String,?> sourceOffset, java.lang.String topic, Schema valueSchema, java.lang.Object value)
SourceRecord(java.util.Map<java.lang.String,?> sourcePartition, java.util.Map<java.lang.String,?> sourceOffset, java.lang.String topic, Schema keySchema, java.lang.Object key, Schema valueSchema, java.lang.Object value)

Method Summary

Modifier and Type	Method and Description
boolean	equals(java.lang.Object o)
int	hashCode()
SourceRecord	newRecord(java.lang.String topic, java.lang.Integer kafkaPartition, Schema keySchema, java.lang.Object key, Schema valueSchema, java.lang.Object value, java.lang.Long timestamp) Generate a new record of the same type as itself, with the specified parameter values.
java.util.Map<java.lang.String,?>	sourceOffset()
java.util.Map<java.lang.String,?>	sourcePartition()
java.lang.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

SourceRecord

public SourceRecord(java.util.Map<java.lang.String,?> sourcePartition,
                    java.util.Map<java.lang.String,?> sourceOffset,
                    java.lang.String topic,
                    java.lang.Integer partition,
                    Schema valueSchema,
                    java.lang.Object value)

SourceRecord

public SourceRecord(java.util.Map<java.lang.String,?> sourcePartition,
                    java.util.Map<java.lang.String,?> sourceOffset,
                    java.lang.String topic,
                    Schema valueSchema,
                    java.lang.Object value)

SourceRecord

public SourceRecord(java.util.Map<java.lang.String,?> sourcePartition,
                    java.util.Map<java.lang.String,?> sourceOffset,
                    java.lang.String topic,
                    Schema keySchema,
                    java.lang.Object key,
                    Schema valueSchema,
                    java.lang.Object value)

SourceRecord

public SourceRecord(java.util.Map<java.lang.String,?> sourcePartition,
                    java.util.Map<java.lang.String,?> sourceOffset,
                    java.lang.String topic,
                    java.lang.Integer partition,
                    Schema keySchema,
                    java.lang.Object key,
                    Schema valueSchema,
                    java.lang.Object value)

SourceRecord

public SourceRecord(java.util.Map<java.lang.String,?> sourcePartition,
                    java.util.Map<java.lang.String,?> sourceOffset,
                    java.lang.String topic,
                    java.lang.Integer partition,
                    Schema keySchema,
                    java.lang.Object key,
                    Schema valueSchema,
                    java.lang.Object value,
                    java.lang.Long timestamp)

Method Detail

sourcePartition

public java.util.Map<java.lang.String,?> sourcePartition()

sourceOffset

public java.util.Map<java.lang.String,?> sourceOffset()

newRecord

public SourceRecord newRecord(java.lang.String topic,
                              java.lang.Integer kafkaPartition,
                              Schema keySchema,
                              java.lang.Object key,
                              Schema valueSchema,
                              java.lang.Object value,
                              java.lang.Long timestamp)

Description copied from class: ConnectRecord

Generate a new record of the same type as itself, with the specified parameter values.

Specified by:

newRecord in class ConnectRecord<SourceRecord>

equals

public boolean equals(java.lang.Object o)

Overrides:

equals in class ConnectRecord<SourceRecord>

hashCode

public int hashCode()

Overrides:

hashCode in class ConnectRecord<SourceRecord>

toString

public java.lang.String toString()

Overrides:

toString in class ConnectRecord<SourceRecord>