Class ByteBufferSerializer
java.lang.Object
org.apache.kafka.common.serialization.ByteBufferSerializer
- All Implemented Interfaces:
Closeable
,AutoCloseable
,Serializer<ByteBuffer>
ByteBufferSerializer
always rewinds
the position of the input buffer to zero for
serialization. A manual rewind is not necessary.
Note: any existing buffer position is ignored.
The position is also rewound back to zero before serialize(String, ByteBuffer)
returns.
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionbyte[]
serialize
(String topic, ByteBuffer data) Convertdata
into a byte array.Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.apache.kafka.common.serialization.Serializer
close, configure, serialize
-
Constructor Details
-
ByteBufferSerializer
public ByteBufferSerializer()
-
-
Method Details
-
serialize
Description copied from interface:Serializer
Convertdata
into a byte array.- Specified by:
serialize
in interfaceSerializer<ByteBuffer>
- Parameters:
topic
- topic associated with datadata
- typed data- Returns:
- serialized bytes
-