Class FailedDeserializationInfo


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

      Constructors 
      Constructor Description
      FailedDeserializationInfo​(java.lang.String topic, org.apache.kafka.common.header.Headers headers, byte[] data, boolean isForKey, java.lang.Exception exception)
      Construct an instance with the contextual information.
    • Constructor Detail

      • FailedDeserializationInfo

        public FailedDeserializationInfo​(java.lang.String topic,
                                         org.apache.kafka.common.header.Headers headers,
                                         byte[] data,
                                         boolean isForKey,
                                         java.lang.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 Detail

      • getTopic

        public java.lang.String getTopic()
      • getHeaders

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

        public byte[] getData()
      • isForKey

        public boolean isForKey()
      • getException

        public java.lang.Exception getException()
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object