Skip to content


RowDeserializer is a Deserializer (Apache Kafka) of java.util.List.

Creating Instance

RowDeserializer takes the following to be created:

  • Delegate Deserializer<?>

RowDeserializer is created when:

Deserializing Record

List<?> deserialize(
  String topic,
  byte[] bytes)

deserialize is part of the Deserializer (Apache Kafka) abstraction.

deserialize requests the delegate Deserializer to deserialize the given bytes.

If the deserialized value is null, deserialize returns null.

Otherwise, deserialize returns a single-element collection with the deserialized value.

In case of any exception while deserializing the bytes, deserialize throws a SerializationException:

Error deserializing KAFKA message from topic: [topic]