public class StringConverter extends Object implements Converter, HeaderConverter
Converter
and HeaderConverter
implementation that only supports serializing to strings. When converting Kafka Connect
data to bytes, the schema will be ignored and Object.toString()
will always be invoked to convert the data to a String.
When converting from bytes to Kafka Connect format, the converter will only ever return an optional string schema and
a string or null.
Encoding configuration is identical to StringSerializer
and StringDeserializer
, but for convenience
this class can also be configured to use the same encoding for both encoding and decoding with the
converter.encoding
setting.
This implementation currently does nothing with the topic names or header names.Constructor and Description |
---|
StringConverter() |
Modifier and Type | Method and Description |
---|---|
void |
close() |
org.apache.kafka.common.config.ConfigDef |
config()
Configuration specification for this converter.
|
void |
configure(Map<String,?> configs) |
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.
|
byte[] |
fromConnectHeader(String topic,
String headerKey,
Schema schema,
Object value)
|
SchemaAndValue |
toConnectData(String topic,
byte[] value)
Convert a native object to a Kafka Connect data object.
|
SchemaAndValue |
toConnectHeader(String topic,
String headerKey,
byte[] value)
Convert the header name and byte array value into a
Header object. |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
fromConnectData, toConnectData
public org.apache.kafka.common.config.ConfigDef config()
Converter
config
in interface Converter
config
in interface HeaderConverter
public void configure(Map<String,?> configs)
configure
in interface org.apache.kafka.common.Configurable
public void configure(Map<String,?> configs, boolean isKey)
Converter
public byte[] fromConnectData(String topic, Schema schema, Object value)
Converter
fromConnectData
in interface Converter
topic
- the topic associated with the dataschema
- the schema for the valuevalue
- the value to convertpublic SchemaAndValue toConnectData(String topic, byte[] value)
Converter
toConnectData
in interface Converter
topic
- the topic associated with the datavalue
- the value to convertSchema
and the converted valuepublic byte[] fromConnectHeader(String topic, String headerKey, Schema schema, Object value)
HeaderConverter
fromConnectHeader
in interface HeaderConverter
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 nullpublic SchemaAndValue toConnectHeader(String topic, String headerKey, byte[] value)
HeaderConverter
Header
object.toConnectHeader
in interface HeaderConverter
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 nullSchemaAndValue
; may not be nullpublic void close()
close
in interface Closeable
close
in interface AutoCloseable