[
https://issues.apache.org/jira/browse/KAFKA-5078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin updated KAFKA-5078:
--------------------------------
Fix Version/s: 0.11.0.0
> 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
> Fix For: 0.11.0.0
>
>
> 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)
