org.apache.kafka.connect.storage

Interface Converter

All Known Implementing Classes:

StringConverter

@InterfaceStability.Unstable
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

Methods

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

Method Detail

configure

void configure(Map<String,?> configs,
             boolean isKey)

Configure this class.

Parameters:

configs - configs in key/value pairs

isKey - whether is for key or value

fromConnectData

byte[] fromConnectData(String topic,
                     Schema schema,
                     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(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