[
https://issues.apache.org/jira/browse/KAFKA-5078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-5078:
----------------------------
Description:
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 defer exception to the next call of
PartitionRecords.fetchRecords(...) if iterator has already moved across any
valid record.
> 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 defer 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)
