io.confluent.kafka.serializers

Class KafkaJsonDecoder<T>

java.lang.Object

io.confluent.kafka.serializers.KafkaJsonDeserializer<T>

io.confluent.kafka.serializers.KafkaJsonDecoder<T>

All Implemented Interfaces:

Closeable, AutoCloseable, kafka.serializer.Decoder<T>, org.apache.kafka.common.serialization.Deserializer<T>

public class KafkaJsonDecoder<T>
extends KafkaJsonDeserializer<T>
implements kafka.serializer.Decoder<T>

Decode JSON data to an Object.

Constructor Summary

Constructors

Constructor and Description
KafkaJsonDecoder(kafka.utils.VerifiableProperties props) This constructor is needed by Kafka.
KafkaJsonDecoder(kafka.utils.VerifiableProperties props, Class<T> type) Create a new decoder using the expected type to decode to

Method Summary

Modifier and Type	Method and Description
T	fromBytes(byte[] bytes)

Methods inherited from class io.confluent.kafka.serializers.KafkaJsonDeserializer

close, configure, configure, deserialize, getType, objectMapper

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.kafka.common.serialization.Deserializer

deserialize, deserialize

Constructor Detail

KafkaJsonDecoder

public KafkaJsonDecoder(kafka.utils.VerifiableProperties props)

This constructor is needed by Kafka. When used directly or through reflection, the type will default to Object since there is no way to infer a generic type. In particular, it is an error to do the following:

   // WARNING: DON'T DO THIS
   KafkaJsonDecoder<String> decoder = new KafkaJsonDecoder<String>(props);
   
 

Instead you must use KafkaJsonDecoder(VerifiableProperties, Class) with the expected type.

Parameters:

props - The decoder configuration

KafkaJsonDecoder

public KafkaJsonDecoder(kafka.utils.VerifiableProperties props,
                        Class<T> type)

Create a new decoder using the expected type to decode to

Parameters:

props - The decoder configuration

type - The type of objects constructed

Method Detail

fromBytes

public T fromBytes(byte[] bytes)

Specified by:

fromBytes in interface kafka.serializer.Decoder<T>