[jira] [Commented] (KAFKA-7204) MockConsumer poll clears all records in poll(), including records for subscriptions that are paused.

["ASF GitHub Bot (Jira)" <ji...@apache.org>]

    [ 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:
users@infra.apache.org


> 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)