[ https://issues.apache.org/jira/browse/KAFKA-6083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Ewen Cheslack-Postava updated KAFKA-6083: ----------------------------------------- Fix Version/s: (was: 1.0.1) 1.0.2 Seems the PR is still in flight, moving from 1.0.1 to 1.0.2 so we can get 1.0.1 out the door. > 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 > Priority: Major > Labels: newbie++ > Fix For: 1.0.2 > > > 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 (v7.6.3#76005)