io.micronaut.configuration.kafka.serde

Class JsonSerde<T>

java.lang.Object

io.micronaut.configuration.kafka.serde.JsonSerde<T>

Type Parameters:

T - The type to serialize/deserialize

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, org.apache.kafka.common.serialization.Deserializer<T>, org.apache.kafka.common.serialization.Serde<T>, org.apache.kafka.common.serialization.Serializer<T>

@Prototype
public class JsonSerde<T>
extends java.lang.Object
implements org.apache.kafka.common.serialization.Serializer<T>, org.apache.kafka.common.serialization.Deserializer<T>, org.apache.kafka.common.serialization.Serde<T>

A Serializer and Deserializer for JSON.

Since:

1.0

Author:

Graeme Rocher

Constructor Summary

Constructors

Constructor and Description
JsonSerde(java.lang.Class<T> type) Constructs a new instance for the given arguments.
JsonSerde(io.micronaut.jackson.serialize.JacksonObjectSerializer objectSerializer, java.lang.Class<T> type) Constructs a new instance for the given arguments.
JsonSerde(com.fasterxml.jackson.databind.ObjectMapper objectMapper, java.lang.Class<T> type) Constructs a new instance for the given arguments.

Method Summary

Modifier and Type	Method and Description
void	close()
void	configure(java.util.Map<java.lang.String,?> configs, boolean isKey)
T	deserialize(java.lang.String topic, byte[] data)
org.apache.kafka.common.serialization.Deserializer<T>	deserializer()
byte[]	serialize(java.lang.String topic, T data)
org.apache.kafka.common.serialization.Serializer<T>	serializer()
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

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

serialize

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

deserialize

Constructor Detail

JsonSerde

@Inject
public JsonSerde(io.micronaut.jackson.serialize.JacksonObjectSerializer objectSerializer,
                         @Parameter
                         java.lang.Class<T> type)

Constructs a new instance for the given arguments.

Parameters:

objectSerializer - The JacksonObjectSerializer

type - The target type

JsonSerde

public JsonSerde(java.lang.Class<T> type)

Constructs a new instance for the given arguments. Using a default ObjectMapper

Parameters:

type - The target type

JsonSerde

public JsonSerde(com.fasterxml.jackson.databind.ObjectMapper objectMapper,
                 java.lang.Class<T> type)

Constructs a new instance for the given arguments. Using a default ObjectMapper

Parameters:

objectMapper - The object mapper to use

type - The target type

Method Detail

deserialize

public T deserialize(java.lang.String topic,
                     byte[] data)

Specified by:

deserialize in interface org.apache.kafka.common.serialization.Deserializer<T>

configure

public void configure(java.util.Map<java.lang.String,?> configs,
                      boolean isKey)

Specified by:

configure in interface org.apache.kafka.common.serialization.Deserializer<T>

Specified by:

configure in interface org.apache.kafka.common.serialization.Serde<T>

Specified by:

configure in interface org.apache.kafka.common.serialization.Serializer<T>

serialize

public byte[] serialize(java.lang.String topic,
                        T data)

Specified by:

serialize in interface org.apache.kafka.common.serialization.Serializer<T>

close

public void close()

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface org.apache.kafka.common.serialization.Deserializer<T>

Specified by:

close in interface org.apache.kafka.common.serialization.Serde<T>

Specified by:

close in interface org.apache.kafka.common.serialization.Serializer<T>

serializer

public org.apache.kafka.common.serialization.Serializer<T> serializer()

Specified by:

serializer in interface org.apache.kafka.common.serialization.Serde<T>

deserializer

public org.apache.kafka.common.serialization.Deserializer<T> deserializer()

Specified by:

deserializer in interface org.apache.kafka.common.serialization.Serde<T>

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object