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>