Details
-
Bug
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
None
-
None
-
None
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 deferring exception to the next call of PartitionRecords.fetchRecords(...) if iterator has already moved across any valid record.
Attachments
Issue Links
- is related to
-
KAFKA-4740 Using new consumer API with a Deserializer that throws SerializationException can lead to infinite loop
- Open
- links to