[KAFKA-14724] Port tests in FetcherTest to FetchRequestManagerTest

• Type: Task
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Component/s: clients, consumer
• Labels: consumer-threading-refactor
• Assignee: Kirk True
• Reporter: Kirk True
• Created: 15/Feb/23 19:43
• Updated: 31/Jul/23 23:49

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.

Issue Links

• is blocked by: KAFKA-14274 Introduce FetchRequestManager to integrate fetch into new consumer threading refactor
• is part of: KAFKA-14246 Update threading model for Consumer