Serialized Form

Package com.github.jcustenborder.kafka.connect.utils.data

Class com.github.jcustenborder.kafka.connect.utils.data.SourceRecordConcurrentLinkedDeque extends ConcurrentLinkedDeque<org.apache.kafka.connect.source.SourceRecord> implements Serializable

Serialized Fields

batchSize

int batchSize

timeout

int timeout

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

Class com.github.jcustenborder.kafka.connect.utils.jackson.ConfigDefSerializationModule extends com.fasterxml.jackson.databind.module.SimpleModule implements Serializable

Class com.github.jcustenborder.kafka.connect.utils.jackson.HeaderSerializationModule extends com.fasterxml.jackson.databind.module.SimpleModule implements Serializable

Class com.github.jcustenborder.kafka.connect.utils.jackson.SchemaSerializationModule extends com.fasterxml.jackson.databind.module.SimpleModule implements Serializable

Class com.github.jcustenborder.kafka.connect.utils.jackson.SinkRecordSerializationModule extends com.fasterxml.jackson.databind.module.SimpleModule implements Serializable

Class com.github.jcustenborder.kafka.connect.utils.jackson.SourceRecordSerializationModule extends com.fasterxml.jackson.databind.module.SimpleModule implements Serializable

Class com.github.jcustenborder.kafka.connect.utils.jackson.StructSerializationModule extends com.fasterxml.jackson.databind.module.SimpleModule implements Serializable

Class com.github.jcustenborder.kafka.connect.utils.jackson.TimeSerializationModule extends com.fasterxml.jackson.databind.module.SimpleModule implements Serializable