Class ListDeserializer<Inner>

java.lang.Object
org.apache.kafka.common.serialization.ListDeserializer<Inner>
All Implemented Interfaces:
Closeable, AutoCloseable, Deserializer<List<Inner>>
public class ListDeserializer<Inner>extends Object implements Deserializer<List<Inner>>

  • Constructor Details

    • ListDeserializer

      public ListDeserializer()

    • ListDeserializer

      public <L extends List<Inner>> ListDeserializer(Class<L> listClass, Deserializer<Inner> inner)

  • Method Details

    • innerDeserializer

      public Deserializer<Inner> innerDeserializer()

    • configure

      public void configure(Map<String,?> configs, boolean isKey)
      Description copied from interface: Deserializer
      Configure this class.
      Specified by:
      configure in interface Deserializer<Inner>
      Parameters:
      configs - configs in key/value pairs
      isKey - whether the deserializer is used for the key or the value

    • deserialize

      public List<Inner> deserialize(String topic, byte[] data)
      Description copied from interface: Deserializer
      Deserialize a record value from a byte array into a value or object.

      It is recommended to deserialize a null byte array to a null object.

      Specified by:
      deserialize in interface Deserializer<Inner>
      Parameters:
      topic - topic associated with the data
      data - serialized bytes; may be null
      Returns:
      deserialized typed data; may be null

    • deserialize

      public List<Inner> deserialize(String topic, Headers headers, byte[] data)
      Description copied from interface: Deserializer
      Deserialize a record value from a byte array into a value or object.

      It is recommended to deserialize a null byte array to a null object.

      Note that the passed in Headers may be empty, but never null. The implementation is allowed to modify the passed in headers, as a side effect of deserialization. It is considered best practice to not delete or modify existing headers, but rather only add new ones.

      Specified by:
      deserialize in interface Deserializer<Inner>
      Parameters:
      topic - topic associated with the data
      headers - headers associated with the record
      data - serialized bytes; may be null
      Returns:
      deserialized typed data; may be null

    • close

      public void close()
      Description copied from interface: Deserializer
      Close this deserializer.

      This method must be idempotent as it may be called multiple times.

      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface Closeable
      Specified by:
      close in interface Deserializer<Inner>