Hello All, I'd like to start a discussion for KIP-1218. https://cwiki.apache.org/confluence/x/NQrxFg
This proposal aims to expose the CorruptRecordException directly from the consumer when a corrupted record is found on the broker. Currently, a generic KafkaException is thrown, which prevents clients from handling this specific error case. Regards, Uladzislau Blok.
