Package org.apache.kafka.connect.storage
Interface HeaderConverter
- All Superinterfaces:
AutoCloseable
,Closeable
,Configurable
- All Known Implementing Classes:
SimpleHeaderConverter
,StringConverter
-
Method Summary
Modifier and TypeMethodDescriptionconfig()
Configuration specification for this set of header converters.byte[]
fromConnectHeader
(String topic, String headerKey, Schema schema, Object value) toConnectHeader
(String topic, String headerKey, byte[] value) Convert the header name and byte array value into aHeader
object.Methods inherited from interface org.apache.kafka.common.Configurable
configure
-
Method Details
-
toConnectHeader
Convert the header name and byte array value into aHeader
object.- Parameters:
topic
- the name of the topic for the record containing the headerheaderKey
- the header's key; may not be nullvalue
- the header's raw value; may be null- Returns:
- the
SchemaAndValue
; may not be null
-
fromConnectHeader
- Parameters:
topic
- the name of the topic for the record containing the headerheaderKey
- the header's key; may not be nullschema
- the schema for the header's value; may be nullvalue
- 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
-