Hi all, I'm reviving this discussion after perusing the vote thread created by Stan. I believe the KIP is already revised to include Jason and Colin's suggestion of using a RecordDeserializationException. It signals to the user that something needs to be done (whether skipping the record as shown in the example and/or do something else). This is backward compatible with what we have today and is clean.
Mathias suggested that we split the exception types into a RecordDeserializationException and a CorruptRecordException with the intention of auto-skipping corrupt records. I would prefer to use another KIP for that type of functionality. KIP: https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=87297793 JIRAs: https://issues.apache.org/jira/browse/KAFKA-5682 Last Vote thread comment from Stan: https://www.mail-archive.com/dev@kafka.apache.org/msg92392.html On another note, I need edit access to the KIP page. Could somebody give me access should I need to make changes? My username is sarwarb. Thanks. Sarwar
