KafkaRecordDecodeFailure

constructor(record: ReceiverRecord<String, String>, cause: Exception)