Details
-
Sub-task
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
None
Description
The Fetcher class is used internally by the KafkaConsumer to fetch records from the brokers. There is ongoing work to create a new consumer implementation with a significantly refactored threading model. The threading refactor work requires a similarly refactored Fetcher.
This task involves copying the relevant tests from FetcherTest and modifying them to fit a new unit test named FetchRequestManagerTest.
Attachments
Issue Links
- is blocked by
-
KAFKA-14274 Introduce FetchRequestManager to integrate fetch into new consumer threading refactor
- Resolved
- is part of
-
KAFKA-14246 Update threading model for Consumer
- Resolved
- is related to
-
KAFKA-14274 Introduce FetchRequestManager to integrate fetch into new consumer threading refactor
- Resolved