com.github.jcustenborder.kafka.connect.utils.jackson

Class SinkRecordSerializationModule.Storage

java.lang.Object

com.github.jcustenborder.kafka.connect.utils.jackson.SinkRecordSerializationModule.Storage

Enclosing class:

SinkRecordSerializationModule

public static class SinkRecordSerializationModule.Storage
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
List<org.apache.kafka.connect.header.Header>	headers
Integer	kafkaPartition
Object	key
org.apache.kafka.connect.data.Schema	keySchema
long	offset
Long	timestamp
org.apache.kafka.common.record.TimestampType	timestampType
String	topic
Object	value
org.apache.kafka.connect.data.Schema	valueSchema

Constructor Summary

Constructors

Constructor and Description
Storage()

Method Summary

Modifier and Type	Method and Description
org.apache.kafka.connect.sink.SinkRecord	build()
Object	key()
Object	value()

Methods inherited from class java.lang.Object

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

Field Detail

topic

public String topic

kafkaPartition

public Integer kafkaPartition

keySchema

public org.apache.kafka.connect.data.Schema keySchema

key

public Object key

valueSchema

public org.apache.kafka.connect.data.Schema valueSchema

value

public Object value

timestamp

public Long timestamp

timestampType

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

offset

public long offset

headers

public List<org.apache.kafka.connect.header.Header> headers

Constructor Detail

Storage

public Storage()

Method Detail

value

public Object value()

key

public Object key()

build

public org.apache.kafka.connect.sink.SinkRecord build()