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, org.apache.kafka.common.serialization.Deserializer<T>, org.apache.kafka.common.serialization.Serde<T>, org.apache.kafka.common.serialization.Serializer<T>

@Prototype
public class JsonObjectSerde<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:

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)
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

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 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