[
https://issues.apache.org/jira/browse/KAFKA-5078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16007565#comment-16007565
]
ASF GitHub Bot commented on KAFKA-5078:
---------------------------------------
Github user asfgit closed the pull request at:
https://github.com/apache/kafka/pull/2864
> PartitionRecords.fetchRecords(...) should defer exception to the next call if
> iterator has already moved across any valid record
> --------------------------------------------------------------------------------------------------------------------------------
>
> Key: KAFKA-5078
> URL: https://issues.apache.org/jira/browse/KAFKA-5078
> Project: Kafka
> Issue Type: Bug
> Reporter: Dong Lin
> Assignee: Dong Lin
>
> Suppose there are two valid records followed by one invalid records in the
> FetchResponse.PartitionData(). As of current implementation,
> PartitionRecords.fetchRecords(...) will throw exception without returning the
> two valid records. The next call to PartitionRecords.fetchRecords(...) will
> not return that two valid records either because the iterator has already
> moved across them.
> We can fix this problem by deferring exception to the next call of
> PartitionRecords.fetchRecords(...) if iterator has already moved across any
> valid record.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
