public class EncoderAdaptingSerializer<T>
extends java.lang.Object
implements org.apache.kafka.common.serialization.Serializer<T>
Encoder
to the Serializer
interface used
by the new client.Constructor and Description |
---|
EncoderAdaptingSerializer(kafka.serializer.Encoder<T> encoder) |
public EncoderAdaptingSerializer(kafka.serializer.Encoder<T> encoder)
public kafka.serializer.Encoder<T> getEncoder()
public void configure(java.util.Map<java.lang.String,?> configs, boolean isKey)
configure
in interface org.apache.kafka.common.serialization.Serializer<T>
public byte[] serialize(java.lang.String topic, T data)
serialize
in interface org.apache.kafka.common.serialization.Serializer<T>
public void close()
close
in interface org.apache.kafka.common.serialization.Serializer<T>