Package io.micronaut.configuration.kafka.serde

Class JsonObjectSerde<T>

java.lang.Object

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

Type Parameters:

T - The type to serialize/deserialize

All Implemented Interfaces:

Closeable, AutoCloseable, Deserializer<T>, Serde<T>, Serializer<T>

@Prototype
public class JsonObjectSerde<T>
extends Object
implements Serializer<T>, Deserializer<T>, Serde<T>

A Serializer and Deserializer for JSON.

Since:

4.1.0

Author:

Denis Stepanov

Constructor Summary

Constructors

Constructor	Description
JsonObjectSerde(io.micronaut.json.JsonObjectSerializer objectSerializer, Class<T> type)	Constructs a new instance for the given arguments.

Method Summary

Modifier and Type	Method	Description
void	close()
void	configure(Map<String,?> configs, boolean isKey)
T	deserialize(String topic, byte[] data)
Deserializer<T>	deserializer()
byte[]	serialize(String topic, T data)
Serializer<T>	serializer()
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.Deserializer

deserialize, deserialize

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

serialize

Constructor Details

JsonObjectSerde

@Creator
public JsonObjectSerde(io.micronaut.json.JsonObjectSerializer objectSerializer,
 @Parameter
 Class<T> type)

Constructs a new instance for the given arguments.

Parameters:

objectSerializer - The JsonObjectSerializer

type - The target type

Method Details

deserialize

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

Specified by:

deserialize in interface Deserializer<T>

configure

public void configure(Map<String,?> configs,
 boolean isKey)

Specified by:

configure in interface Deserializer<T>

Specified by:

configure in interface Serde<T>

Specified by:

configure in interface Serializer<T>

serialize

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

Specified by:

serialize in interface Serializer<T>

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface Deserializer<T>

Specified by:

close in interface Serde<T>

Specified by:

close in interface Serializer<T>

serializer

public Serializer<T> serializer()

Specified by:

serializer in interface Serde<T>

deserializer

public Deserializer<T> deserializer()

Specified by:

deserializer in interface Serde<T>

toString

public String toString()

Overrides:

toString in class Object