public class SchemalessConverter<T> extends AbstractKafkaSerDe<SchemalessConverter<T>> implements org.apache.kafka.connect.storage.Converter
applySchema(Schema, Object)
and
#provideSchema(T)
or #toSchemaAndValue(T)
.Modifier and Type | Field and Description |
---|---|
protected org.apache.kafka.common.serialization.Deserializer<T> |
deserializer |
static String |
REGISTRY_CONVERTER_DESERIALIZER_PARAM |
static String |
REGISTRY_CONVERTER_SERIALIZER_PARAM |
protected org.apache.kafka.common.serialization.Serializer<T> |
serializer |
log, MAGIC_BYTE, REGISTRY_CACHED_CONFIG_PARAM, REGISTRY_CONFLUENT_ID_HANDLER_CONFIG_PARAM, REGISTRY_ID_HANDLER_CONFIG_PARAM, REGISTRY_URL_CONFIG_PARAM
Constructor and Description |
---|
SchemalessConverter() |
SchemalessConverter(org.apache.kafka.common.serialization.Serde<T> serde) |
SchemalessConverter(org.apache.kafka.common.serialization.Serializer<T> serializer,
org.apache.kafka.common.serialization.Deserializer<T> deserializer) |
Modifier and Type | Method and Description |
---|---|
protected T |
applySchema(org.apache.kafka.connect.data.Schema schema,
Object value) |
void |
close() |
void |
configure(Map<String,?> configs,
boolean isKey) |
protected Class<? extends org.apache.kafka.common.serialization.Deserializer> |
deserializerClass() |
byte[] |
fromConnectData(String topic,
org.apache.kafka.connect.data.Schema schema,
Object value) |
protected org.apache.kafka.connect.data.Schema |
provideSchema(T result) |
protected Class<? extends org.apache.kafka.common.serialization.Serializer> |
serializerClass() |
void |
setDeserializer(org.apache.kafka.common.serialization.Deserializer<T> deserializer) |
void |
setSerializer(org.apache.kafka.common.serialization.Serializer<T> serializer) |
org.apache.kafka.connect.data.SchemaAndValue |
toConnectData(String topic,
byte[] bytes) |
protected org.apache.kafka.connect.data.SchemaAndValue |
toSchemaAndValue(T result) |
asLegacyId, configure, getByteBuffer, getClient, getIdHandler, instantiate, instantiate, loadClass, reset, self, setIdHandler
public static final String REGISTRY_CONVERTER_SERIALIZER_PARAM
public static final String REGISTRY_CONVERTER_DESERIALIZER_PARAM
protected org.apache.kafka.common.serialization.Serializer<T> serializer
protected org.apache.kafka.common.serialization.Deserializer<T> deserializer
public SchemalessConverter()
public SchemalessConverter(org.apache.kafka.common.serialization.Serde<T> serde)
protected Class<? extends org.apache.kafka.common.serialization.Serializer> serializerClass()
protected Class<? extends org.apache.kafka.common.serialization.Deserializer> deserializerClass()
public void configure(Map<String,?> configs, boolean isKey)
configure
in interface org.apache.kafka.connect.storage.Converter
public void close()
close
in interface AutoCloseable
close
in class AbstractKafkaSerDe<SchemalessConverter<T>>
public byte[] fromConnectData(String topic, org.apache.kafka.connect.data.Schema schema, Object value)
fromConnectData
in interface org.apache.kafka.connect.storage.Converter
protected org.apache.kafka.connect.data.Schema provideSchema(T result)
protected org.apache.kafka.connect.data.SchemaAndValue toSchemaAndValue(T result)
public org.apache.kafka.connect.data.SchemaAndValue toConnectData(String topic, byte[] bytes)
toConnectData
in interface org.apache.kafka.connect.storage.Converter
public void setSerializer(org.apache.kafka.common.serialization.Serializer<T> serializer)
public void setDeserializer(org.apache.kafka.common.serialization.Deserializer<T> deserializer)
Copyright © 2020 Red Hat. All rights reserved.