[
https://issues.apache.org/jira/browse/KAFKA-7204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16950013#comment-16950013
]
ASF GitHub Bot commented on KAFKA-7204:
---------------------------------------
efgpinto commented on pull request #7505: KAFKA-7204: Avoid clearing records
for paused partitions on poll of MockConsumer
URL: https://github.com/apache/kafka/pull/7505
The previous version of MockConsumer does not allow the clients to test
consecutive calls to poll while consuming only from a partial set of partitions
due to the fact that it clears all the records after each call. This change
makes MockConsumer clearing the records only for the partitions that are not
paused (whose records are actually returned by the poll). The remaining paused
partitions will retain the records.
Unit test added accordingly.
### Committer Checklist (excluded from commit message)
- [x] Verify design and implementation
- [x] Verify test coverage and CI build status
- [x] Verify documentation (including upgrade notes)
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
> MockConsumer poll clears all records in poll(), including records for
> subscriptions that are paused.
> ----------------------------------------------------------------------------------------------------
>
> Key: KAFKA-7204
> URL: https://issues.apache.org/jira/browse/KAFKA-7204
> Project: Kafka
> Issue Type: Bug
> Components: consumer
> Affects Versions: 1.1.0
> Reporter: Subodh Bhattacharjya
> Priority: Minor
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
