[ 
https://issues.apache.org/jira/browse/KAFKA-3427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15203351#comment-15203351
 ] 

Jun Rao commented on KAFKA-3427:
--------------------------------

[~aauradkar], do you think you could patch this for the 0.9.0 branch as well? 
In addition to patch FetchResponse.handleError(), we also need to patch 
ProduceResponse.handleError() since we added the throttledTime in the response 
and we were still using the old Scala request/response in KafkaApis in 0.9.0. 
Thanks,

> broker can return incorrect version of fetch response when the broker hits an 
> unknown exception
> -----------------------------------------------------------------------------------------------
>
>                 Key: KAFKA-3427
>                 URL: https://issues.apache.org/jira/browse/KAFKA-3427
>             Project: Kafka
>          Issue Type: Bug
>    Affects Versions: 0.9.0.1, 0.10.0.0
>            Reporter: Jun Rao
>            Assignee: Jun Rao
>            Priority: Blocker
>             Fix For: 0.10.0.0
>
>
> In FetchResponse.handleError(), we generate FetchResponse like the following, 
> which always defaults to version 0 of the response. 
>     FetchResponse(correlationId, fetchResponsePartitionData)



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to