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 covers the work to extract from Fetcher the APIs that are related to metadata operations into a new class named MetadataFetcher. This will allow the refactoring of Fetcher and MetadataFetcher for the new consumer.
Attachments
Issue Links
- is part of
-
KAFKA-14246 Refactor KafkaConsumer Threading Model
-
- In Progress
-
- links to