xiaoqingwanga opened a new pull request, #16303: URL: https://github.com/apache/kafka/pull/16303
This PR refactors the ConsumerTaskTest. It extracts the single loop iteration within the run method of ConsumerTask into a separate method called ingestRecords. The refactored ConsumerTaskTest no longer calls ConsumerTask asynchronously through a background thread, but instead directly invokes the ingestRecords method at different times. All the cases in ConsumerTaskTest have passed the tests. ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage and CI build status - [ ] 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. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
