[jira] [Updated] (KAFKA-6083) The Fetcher should add the InvalidRecordException as a cause to the KafkaException when invalid record is found.

["Ewen Cheslack-Postava (JIRA)" <ji...@apache.org>]

     [ 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)