io.confluent.kafka.streams.serdes.avro

Class SpecificAvroSerializer<T extends org.apache.avro.specific.SpecificRecord>

java.lang.Object

io.confluent.kafka.streams.serdes.avro.SpecificAvroSerializer<T>

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.kafka.common.serialization.Serializer<T>

@InterfaceStability.Unstable
public class SpecificAvroSerializer<T extends org.apache.avro.specific.SpecificRecord>
extends Object
implements org.apache.kafka.common.serialization.Serializer<T>

A schema-registry aware serializer for writing data in "specific 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 SpecificAvroDeserializer for its deserializer counterpart.

Constructor Summary

Constructors

Constructor and Description
SpecificAvroSerializer()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

SpecificAvroSerializer

public SpecificAvroSerializer()

Method Detail

configure

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

Specified by:

configure in interface org.apache.kafka.common.serialization.Serializer<T extends org.apache.avro.specific.SpecificRecord>

serialize

public byte[] serialize(String topic,
                        T record)

Specified by:

serialize in interface org.apache.kafka.common.serialization.Serializer<T extends org.apache.avro.specific.SpecificRecord>

serialize

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

Specified by:

serialize in interface org.apache.kafka.common.serialization.Serializer<T extends org.apache.avro.specific.SpecificRecord>

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<T extends org.apache.avro.specific.SpecificRecord>