Class V2DeserializationFailureEvent


  • public class V2DeserializationFailureEvent
    extends Object
    An event emitted by a streaming operation when an incoming messages fails to deserialize
    • Method Detail

      • getCause

        public Throwable getCause()
        Returns:
        the exception that triggered the failure
      • getPayload

        public byte[] getPayload()
        Returns:
        the payload of the message that triggered the failure
      • getTopic

        public String getTopic()
        Returns:
        the topic of the message that triggered the failure