org.apache.kafka.connect.storage

Interface Converter

All Known Implementing Classes:

StringConverter

public interface Converter

The Converter interface provides support for translating between Kafka Connect's runtime data format and byte[]. Internally, this likely includes an intermediate step to the format used by the serialization layer (e.g. JsonNode, GenericRecord, Message).

Method Summary

Modifier and Type	Method and Description
void	configure(java.util.Map<java.lang.String,?> configs, boolean isKey) Configure this class.
byte[]	fromConnectData(java.lang.String topic, Schema schema, java.lang.Object value) Convert a Kafka Connect data object to a native object for serialization.
SchemaAndValue	toConnectData(java.lang.String topic, byte[] value) Convert a native object to a Kafka Connect data object.

Method Detail

configure

void configure(java.util.Map<java.lang.String,?> configs,
               boolean isKey)

Configure this class.

Parameters:

configs - configs in key/value pairs

isKey - whether is for key or value

fromConnectData

byte[] fromConnectData(java.lang.String topic,
                       Schema schema,
                       java.lang.Object value)

Convert a Kafka Connect data object to a native object for serialization.

Parameters:

topic - the topic associated with the data

schema - the schema for the value

value - the value to convert

Returns:

the serialized value

toConnectData

SchemaAndValue toConnectData(java.lang.String topic,
                             byte[] value)

Convert a native object to a Kafka Connect data object.

Parameters:

topic - the topic associated with the data

value - the value to convert

Returns:

an object containing the Schema and the converted value