public class AvroConverter
extends java.lang.Object
implements org.apache.kafka.connect.storage.Converter
Constructor and Description |
---|
AvroConverter() |
Modifier and Type | Method and Description |
---|---|
void |
configure(java.util.Map<java.lang.String,?> configs,
boolean isKey) |
byte[] |
fromConnectData(java.lang.String topic,
org.apache.kafka.connect.data.Schema schema,
java.lang.Object value) |
org.apache.kafka.connect.data.SchemaAndValue |
toConnectData(java.lang.String topic,
byte[] value) |
public void configure(java.util.Map<java.lang.String,?> configs, boolean isKey)
configure
in interface org.apache.kafka.connect.storage.Converter
public byte[] fromConnectData(java.lang.String topic, org.apache.kafka.connect.data.Schema schema, java.lang.Object value)
fromConnectData
in interface org.apache.kafka.connect.storage.Converter
public org.apache.kafka.connect.data.SchemaAndValue toConnectData(java.lang.String topic, byte[] value)
toConnectData
in interface org.apache.kafka.connect.storage.Converter