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:

java.io.Closeable, java.lang.AutoCloseable, Deserializer<T>, Serde<T>, Serializer<T>

@Internal
 @Prototype
public class JsonObjectSerde<T>
extends java.lang.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 and Description
JsonObjectSerde(io.micronaut.json.JsonObjectSerializer objectSerializer, 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)
Deserializer<T>	deserializer()
byte[]	serialize(java.lang.String topic, T data)
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

JsonObjectSerde

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

Constructs a new instance for the given arguments.

Parameters:

objectSerializer - The JsonObjectSerializer

type - The target type

Method Detail

deserialize

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

Specified by:

deserialize in interface Deserializer<T>

configure

public void configure(java.util.Map<java.lang.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(java.lang.String topic,
                        T data)

Specified by:

serialize in interface 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 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 java.lang.String toString()

Overrides:

toString in class java.lang.Object