Class BytesSerializer

    • Constructor Detail

      • BytesSerializer

        public BytesSerializer()
    • Method Detail

      • serialize

        public byte[] serialize​(String topic,
                                org.apache.kafka.common.utils.Bytes data)
        Description copied from interface: Serializer
        Convert data into a byte array.
        Specified by:
        serialize in interface Serializer<org.apache.kafka.common.utils.Bytes>
        Parameters:
        topic - topic associated with data
        data - typed data
        Returns:
        serialized bytes