Hi everyone, To make implementation of DLQ in consumer easier, I would like to add the raw ConsumerRecord into the RecordDeserializationException.
Details are in KIP-1036 <https://cwiki.apache.org/confluence/display/KAFKA/KIP-1036%3A+Extend+RecordDeserializationException+exception> . Thanks for your feedback. Regards, Fred