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

  org.apache.kafka.common.config.ConfigDef config()

  Configuration specification for this set of header converters.

  Returns:

  the configuration specification; may not be null