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 includes refactoring Fetcher by extracting out the inner classes into top-level (though still in internal) so that those classes can be referenced by forthcoming refactored fetch logic.
Attachments
Issue Links
- blocks
-
KAFKA-14365 Extract common logic from Fetcher
-
- Resolved
-
- is part of
-
-
- In Progress
-
- links to