public class LongSerializerDecoder
extends java.lang.Object
implements org.apache.kafka.common.serialization.Serializer<java.lang.Long>, kafka.serializer.Decoder<java.lang.Long>
Encoder
and Decoder
for Long values.Constructor and Description |
---|
LongSerializerDecoder() |
public java.lang.Long fromBytes(byte[] bytes)
fromBytes
in interface kafka.serializer.Decoder<java.lang.Long>
public void configure(java.util.Map<java.lang.String,?> configs, boolean isKey)
configure
in interface org.apache.kafka.common.serialization.Serializer<java.lang.Long>
public byte[] serialize(java.lang.String topic, java.lang.Long data)
serialize
in interface org.apache.kafka.common.serialization.Serializer<java.lang.Long>
public void close()
close
in interface org.apache.kafka.common.serialization.Serializer<java.lang.Long>