io.confluent.kafka.streams.serdes.avro

Class GenericAvroSerializer

java.lang.Object

io.confluent.kafka.streams.serdes.avro.GenericAvroSerializer

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.kafka.common.serialization.Serializer<org.apache.avro.generic.GenericRecord>

@InterfaceStability.Unstable
public class GenericAvroSerializer
extends Object
implements org.apache.kafka.common.serialization.Serializer<org.apache.avro.generic.GenericRecord>

A schema-registry aware serializer for writing data in "generic Avro" format.

This serializer writes data in the wire format defined at http://docs.confluent.io/current/schema-registry/docs/serializer-formatter.html#wire-format. It requires access to a Confluent Schema Registry endpoint, which you must configure(Map, boolean) via the parameter "schema.registry.url".

See GenericAvroDeserializer for its deserializer counterpart.

Constructor Summary

Constructors

Constructor and Description
GenericAvroSerializer()

Method Summary

Modifier and Type	Method and Description
void	close()
void	configure(Map<String,?> serializerConfig, boolean isSerializerForRecordKeys)
byte[]	serialize(String topic, org.apache.avro.generic.GenericRecord record)
byte[]	serialize(String topic, org.apache.kafka.common.header.Headers headers, org.apache.avro.generic.GenericRecord record)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

GenericAvroSerializer

public GenericAvroSerializer()

Method Detail

configure

public void configure(Map<String,?> serializerConfig,
                      boolean isSerializerForRecordKeys)

Specified by:

configure in interface org.apache.kafka.common.serialization.Serializer<org.apache.avro.generic.GenericRecord>

serialize

public byte[] serialize(String topic,
                        org.apache.avro.generic.GenericRecord record)

Specified by:

serialize in interface org.apache.kafka.common.serialization.Serializer<org.apache.avro.generic.GenericRecord>

serialize

public byte[] serialize(String topic,
                        org.apache.kafka.common.header.Headers headers,
                        org.apache.avro.generic.GenericRecord record)

Specified by:

serialize in interface org.apache.kafka.common.serialization.Serializer<org.apache.avro.generic.GenericRecord>

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Specified by:

close in interface org.apache.kafka.common.serialization.Serializer<org.apache.avro.generic.GenericRecord>