org.apache.kafka.connect.storage

Interface HeaderConverter

All Superinterfaces:

AutoCloseable, Closeable, Configurable

All Known Implementing Classes:

SimpleHeaderConverter, StringConverter

public interface HeaderConverter
extends Configurable, Closeable

Method Summary

Modifier and Type	Method and Description
ConfigDef	config() Configuration specification for this set of header converters.
byte[]	fromConnectHeader(String topic, String headerKey, Schema schema, Object value) Convert the Header's value into its byte array representation.
SchemaAndValue	toConnectHeader(String topic, String headerKey, byte[] value) Convert the header name and byte array value into a Header object.

Methods inherited from interface org.apache.kafka.common.Configurable

configure

Methods inherited from interface java.io.Closeable

close

Method Detail

toConnectHeader

SchemaAndValue toConnectHeader(String topic,
                               String headerKey,
                               byte[] value)

Convert the header name and byte array value into a Header object.

Parameters:

topic - the name of the topic for the record containing the header

headerKey - the header's key; may not be null

value - the header's raw value; may be null

Returns:

the SchemaAndValue; may not be null

fromConnectHeader

byte[] fromConnectHeader(String topic,
                         String headerKey,
                         Schema schema,
                         Object value)

Convert the Header's value into its byte array representation.

Parameters:

topic - the name of the topic for the record containing the header

headerKey - the header's key; may not be null

schema - the schema for the header's value; may be null

value - the header's value to convert; may be null

Returns:

the byte array form of the Header's value; may be null if the value is null

config

ConfigDef config()

Configuration specification for this set of header converters.

Returns:

the configuration specification; may not be null