Package org.springframework.kafka.support.serializer

Class StringOrBytesSerializer

java.lang.Object

org.springframework.kafka.support.serializer.StringOrBytesSerializer

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.kafka.common.serialization.Serializer<Object>

public class StringOrBytesSerializer
extends Object
implements org.apache.kafka.common.serialization.Serializer<Object>

A serializer that can handle byte[], Bytes and String. Convenient when used with one of the Json message converters.

Since:

2.3

Author:

Gary Russell, Ngoc Nhan

Constructor Summary

Constructors

Constructor	Description
StringOrBytesSerializer()

Method Summary

Modifier and Type	Method	Description
void	close()
void	configure(Map<String,?> configs, boolean isKey)
byte @Nullable []	serialize(String topic, @Nullable Object data)
byte @Nullable []	serialize(String topic, org.apache.kafka.common.header.Headers headers, @Nullable Object data)

Methods inherited from class java.lang.Object

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

Constructor Details

StringOrBytesSerializer

public StringOrBytesSerializer()

Method Details

configure

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

Specified by:

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

serialize

public byte @Nullable [] serialize(String topic,
 @Nullable Object data)

Specified by:

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

serialize

public byte @Nullable [] serialize(String topic,
 org.apache.kafka.common.header.Headers headers,
 @Nullable Object data)

Specified by:

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

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

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