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>