[ https://issues.apache.org/jira/browse/KAFKA-6083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jiangjie Qin reassigned KAFKA-6083: ----------------------------------- Assignee: Adem Efe Gencer > The Fetcher should add the InvalidRecordException as a cause to the > KafkaException when invalid record is found. > ---------------------------------------------------------------------------------------------------------------- > > Key: KAFKA-6083 > URL: https://issues.apache.org/jira/browse/KAFKA-6083 > Project: Kafka > Issue Type: Improvement > Components: clients, consumer > Affects Versions: 1.0.0 > Reporter: Jiangjie Qin > Assignee: Adem Efe Gencer > Labels: newbie++ > Fix For: 1.0.1 > > > In the Fetcher, when there is an InvalidRecoredException thrown, we will > convert it to a KafkaException, we should also add the InvalidRecordException > to it as the cause. -- This message was sent by Atlassian JIRA (v6.4.14#64029)