Class ByteBufferDeserializer

java.lang.Object
org.apache.kafka.common.serialization.ByteBufferDeserializer
All Implemented Interfaces:
Closeable, AutoCloseable, Deserializer<ByteBuffer>

public class ByteBufferDeserializer extends Object implements Deserializer<ByteBuffer>
  • Constructor Details

    • ByteBufferDeserializer

      public ByteBufferDeserializer()
  • Method Details

    • deserialize

      public ByteBuffer deserialize(String topic, byte[] data)
      Description copied from interface: Deserializer
      Deserialize a record value from a byte array into a value or object.
      Specified by:
      deserialize in interface Deserializer<ByteBuffer>
      Parameters:
      topic - topic associated with the data
      data - serialized bytes; may be null; implementations are recommended to handle null by returning a value or null rather than throwing an exception.
      Returns:
      deserialized typed data; may be null
    • deserialize

      public ByteBuffer deserialize(String topic, Headers headers, ByteBuffer data)
      Description copied from interface: Deserializer
      Deserialize a record value from a ByteBuffer into a value or object.
      Specified by:
      deserialize in interface Deserializer<ByteBuffer>
      Parameters:
      topic - topic associated with the data
      headers - headers associated with the record; may be empty.
      data - serialized ByteBuffer; may be null; implementations are recommended to handle null by returning a value or null rather than throwing an exception.
      Returns:
      deserialized typed data; may be null