Class BytesSerializer
java.lang.Object
org.apache.kafka.common.serialization.BytesSerializer
- All Implemented Interfaces:
Closeable
,AutoCloseable
,Serializer<org.apache.kafka.common.utils.Bytes>
public class BytesSerializer
extends Object
implements Serializer<org.apache.kafka.common.utils.Bytes>
-
Constructor Details
-
BytesSerializer
public BytesSerializer()
-
-
Method Details
-
serialize
Description copied from interface:Serializer
Convertdata
into a byte array.- Specified by:
serialize
in interfaceSerializer<org.apache.kafka.common.utils.Bytes>
- Parameters:
topic
- topic associated with datadata
- typed data- Returns:
- serialized bytes
-