Class ShortSerializer
java.lang.Object
org.apache.kafka.common.serialization.ShortSerializer
- All Implemented Interfaces:
Closeable,AutoCloseable,Serializer<Short>
Constructor Details
ShortSerializer
public ShortSerializer()
Method Details
serialize
Description copied from interface:SerializerConvertdatainto a byte array.- Specified by:
serializein interfaceSerializer<Short>- Parameters:
topic- topic associated with datadata- typed data- Returns:
- serialized bytes