public class AvroKafkaSerializer<U> extends AbstractKafkaSerializer<org.apache.avro.Schema,U,AvroKafkaSerializer<U>>
REGISTRY_ARTIFACT_ID_STRATEGY_CONFIG_PARAM, REGISTRY_GLOBAL_ID_STRATEGY_CONFIG_PARAM
headerUtils, key, log, MAGIC_BYTE, REGISTRY_CACHED_CONFIG_PARAM, REGISTRY_CONFLUENT_ID_HANDLER_CONFIG_PARAM, REGISTRY_ID_HANDLER_CONFIG_PARAM, REGISTRY_REQUEST_HEADERS_PREFIX, REGISTRY_REQUEST_KEY_PASSWORD, REGISTRY_REQUEST_KEYSTORE_LOCATION, REGISTRY_REQUEST_KEYSTORE_PASSWORD, REGISTRY_REQUEST_KEYSTORE_TYPE, REGISTRY_REQUEST_TRUSTSTORE_LOCATION, REGISTRY_REQUEST_TRUSTSTORE_PASSWORD, REGISTRY_REQUEST_TRUSTSTORE_TYPE, REGISTRY_URL_CONFIG_PARAM, USE_HEADERS
Constructor and Description |
---|
AvroKafkaSerializer() |
AvroKafkaSerializer(RegistryService client) |
AvroKafkaSerializer(RegistryService client,
ArtifactIdStrategy<org.apache.avro.Schema> artifactIdStrategy,
GlobalIdStrategy<org.apache.avro.Schema> idStrategy) |
AvroKafkaSerializer(RegistryService client,
ArtifactIdStrategy<org.apache.avro.Schema> artifactIdStrategy,
GlobalIdStrategy<org.apache.avro.Schema> globalIdStrategy,
AvroDatumProvider<U> avroDatumProvider) |
Modifier and Type | Method and Description |
---|---|
protected io.apicurio.registry.types.ArtifactType |
artifactType() |
void |
configure(Map<String,?> configs,
boolean isKey) |
protected void |
serializeData(org.apache.kafka.common.header.Headers headers,
org.apache.avro.Schema schema,
U data,
ByteArrayOutputStream out) |
protected void |
serializeData(org.apache.avro.Schema schema,
U data,
OutputStream out) |
AvroKafkaSerializer<U> |
setAvroDatumProvider(AvroDatumProvider<U> avroDatumProvider) |
protected org.apache.avro.Schema |
toSchema(U data) |
serialize, serialize
getArtifactIdStrategy, getGlobalIdStrategy, setArtifactIdStrategy, setGlobalIdStrategy
asLegacyId, close, getByteBuffer, getClient, getIdHandler, instantiate, instantiate, isKey, loadClass, reset, self, setIdHandler, setKey, toGlobalId
public AvroKafkaSerializer()
public AvroKafkaSerializer(RegistryService client)
public AvroKafkaSerializer(RegistryService client, ArtifactIdStrategy<org.apache.avro.Schema> artifactIdStrategy, GlobalIdStrategy<org.apache.avro.Schema> idStrategy)
public AvroKafkaSerializer(RegistryService client, ArtifactIdStrategy<org.apache.avro.Schema> artifactIdStrategy, GlobalIdStrategy<org.apache.avro.Schema> globalIdStrategy, AvroDatumProvider<U> avroDatumProvider)
public AvroKafkaSerializer<U> setAvroDatumProvider(AvroDatumProvider<U> avroDatumProvider)
public void configure(Map<String,?> configs, boolean isKey)
configure
in interface org.apache.kafka.common.serialization.Serializer<U>
configure
in class AbstractKafkaStrategyAwareSerDe<org.apache.avro.Schema,AvroKafkaSerializer<U>>
protected org.apache.avro.Schema toSchema(U data)
toSchema
in class AbstractKafkaSerializer<org.apache.avro.Schema,U,AvroKafkaSerializer<U>>
protected io.apicurio.registry.types.ArtifactType artifactType()
artifactType
in class AbstractKafkaSerializer<org.apache.avro.Schema,U,AvroKafkaSerializer<U>>
protected void serializeData(org.apache.avro.Schema schema, U data, OutputStream out) throws IOException
serializeData
in class AbstractKafkaSerializer<org.apache.avro.Schema,U,AvroKafkaSerializer<U>>
IOException
protected void serializeData(org.apache.kafka.common.header.Headers headers, org.apache.avro.Schema schema, U data, ByteArrayOutputStream out) throws IOException
serializeData
in class AbstractKafkaSerializer<org.apache.avro.Schema,U,AvroKafkaSerializer<U>>
IOException
Copyright © 2020 Red Hat. All rights reserved.