Class FailedDeserializationInfo

java.lang.Object
org.springframework.kafka.support.serializer.FailedDeserializationInfo

public class FailedDeserializationInfo extends Object
Class containing all the contextual information around a deserialization error.
Since:
2.2.8
Author:
Victor Perez Rey, Artem Bilan
  • Constructor Details

    • FailedDeserializationInfo

      public FailedDeserializationInfo(String topic, org.apache.kafka.common.header.Headers headers, byte[] data, boolean isForKey, Exception exception)
      Construct an instance with the contextual information.
      Parameters:
      topic - topic associated with the data.
      headers - headers associated with the record; may be empty.
      data - serialized bytes; may be null.
      isForKey - true for a key deserializer, false otherwise.
      exception - exception causing the deserialization error.
  • Method Details

    • getTopic

      public String getTopic()
    • getHeaders

      public org.apache.kafka.common.header.Headers getHeaders()
    • getData

      public byte[] getData()
    • isForKey

      public boolean isForKey()
    • getException

      public Exception getException()
    • toString

      public String toString()
      Overrides:
      toString in class Object