Class BooleanDeserializer

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

public class BooleanDeserializer extends Object implements Deserializer<Boolean>
  • Constructor Details Link icon

    • BooleanDeserializer Link icon

      public BooleanDeserializer()
  • Method Details Link icon

    • deserialize Link icon

      public Boolean 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<Boolean>
      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 Link icon

      public Boolean deserialize(String topic, Headers headers, ByteBuffer data)
      Description copied from interface: Deserializer
      Deserialize a record value from a ByteBuffer into a value or object.

      If ByteBufferDeserializer is used by an application, the application code cannot make any assumptions about the returned ByteBuffer like the position, limit, capacity, etc., or if it is backed by an array or not.

      Similarly, if this method is overridden, the implementation cannot make any assumptions about the passed in ByteBuffer either.

      Specified by:
      deserialize in interface Deserializer<Boolean>
      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