[ https://issues.apache.org/jira/browse/KAFKA-6083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16211720#comment-16211720 ]
ASF GitHub Bot commented on KAFKA-6083: --------------------------------------- Github user efeg closed the pull request at: https://github.com/apache/kafka/pull/4093 > 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)