public class AvroConverter<T> extends SchemalessConverter<T>
deserializer, REGISTRY_CONVERTER_DESERIALIZER_PARAM, REGISTRY_CONVERTER_SERIALIZER_PARAM, 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 |
---|
AvroConverter() |
AvroConverter(AvroKafkaSerializer<T> serializer,
AvroKafkaDeserializer<T> deserializer,
AvroData avroData) |
Modifier and Type | Method and Description |
---|---|
protected T |
applySchema(org.apache.kafka.connect.data.Schema schema,
Object value) |
void |
configure(Map<String,?> configs,
boolean isKey) |
protected Class<? extends org.apache.kafka.common.serialization.Deserializer> |
deserializerClass() |
AvroKafkaDeserializer<T> |
getDeserializer() |
AvroKafkaSerializer<T> |
getSerializer() |
protected Class<? extends org.apache.kafka.common.serialization.Serializer> |
serializerClass() |
protected org.apache.kafka.connect.data.SchemaAndValue |
toSchemaAndValue(T result) |
close, fromConnectData, provideSchema, setDeserializer, setSerializer, toConnectData
asConfluent, configure, getByteBuffer, getClient, getIdHandler, instantiate, instantiate, loadClass, reset, self, setIdHandler
public AvroConverter()
public AvroConverter(AvroKafkaSerializer<T> serializer, AvroKafkaDeserializer<T> deserializer, AvroData avroData)
public void configure(Map<String,?> configs, boolean isKey)
configure
in interface org.apache.kafka.connect.storage.Converter
configure
in class SchemalessConverter<T>
protected T applySchema(org.apache.kafka.connect.data.Schema schema, Object value)
applySchema
in class SchemalessConverter<T>
protected org.apache.kafka.connect.data.SchemaAndValue toSchemaAndValue(T result)
toSchemaAndValue
in class SchemalessConverter<T>
protected Class<? extends org.apache.kafka.common.serialization.Serializer> serializerClass()
serializerClass
in class SchemalessConverter<T>
protected Class<? extends org.apache.kafka.common.serialization.Deserializer> deserializerClass()
deserializerClass
in class SchemalessConverter<T>
public AvroKafkaSerializer<T> getSerializer()
public AvroKafkaDeserializer<T> getDeserializer()
Copyright © 2020 Red Hat. All rights reserved.