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

Class SourceRecordSerializationModule.Storage

java.lang.Object

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

Enclosing class:

SourceRecordSerializationModule

public static class SourceRecordSerializationModule.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
Map<String,?>	sourceOffset
Map<String,?>	sourcePartition
Long	timestamp
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.source.SourceRecord	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

sourcePartition

public Map<String,?> sourcePartition

sourceOffset

public Map<String,?> sourceOffset

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

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.source.SourceRecord build()