org.springframework.kafka.support.serializer

Class JsonSerializer<T>

java.lang.Object

org.springframework.kafka.support.serializer.JsonSerializer<T>

Type Parameters:

T - class of the entity, representing messages

All Implemented Interfaces:

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

public class JsonSerializer<T>
extends java.lang.Object
implements org.apache.kafka.common.serialization.Serializer<T>

Generic Serializer for sending Java objects to Kafka as JSON.

Author:

Igor Stepanov, Artem Bilan

Field Summary

Fields

Modifier and Type	Field and Description
protected com.fasterxml.jackson.databind.ObjectMapper	objectMapper

Constructor Summary

Constructors

Constructor and Description
JsonSerializer()
JsonSerializer(com.fasterxml.jackson.databind.ObjectMapper objectMapper)

Method Summary

Modifier and Type	Method and Description
void	close()
void	configure(java.util.Map<java.lang.String,?> configs, boolean isKey)
byte[]	serialize(java.lang.String topic, T data)

Methods inherited from class java.lang.Object

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

Field Detail

objectMapper

protected final com.fasterxml.jackson.databind.ObjectMapper objectMapper

Constructor Detail

JsonSerializer

public JsonSerializer()

JsonSerializer

public JsonSerializer(com.fasterxml.jackson.databind.ObjectMapper objectMapper)

Method Detail

configure

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

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.Serializer<T>