[ https://issues.apache.org/jira/browse/KAFKA-6083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16210436#comment-16210436 ]
ASF GitHub Bot commented on KAFKA-6083: --------------------------------------- GitHub user efeg reopened a pull request: https://github.com/apache/kafka/pull/4093 KAFKA-6083: The Fetcher should add the InvalidRecordException as a cause to the KafkaException when invalid record is found. You can merge this pull request into a Git repository by running: $ git pull https://github.com/efeg/kafka bug/KAFKA-6083 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/4093.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #4093 ---- commit 88e07d3a3115c4342ad3714d4397ff39b326f12a Author: Adem Efe Gencer <agen...@linkedin.com> Date: 2017-10-19T00:20:04Z Add the InvalidRecordException as a cause to the KafkaException when invalid record is found. ---- > 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)