[KAFKA-15081] Implement new consumer offsetsForTimes

• Type: Sub-task
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 3.7.0
• Component/s: clients, consumer
• Labels: consumer-threading-refactor
• Assignee: Lianet Magrans
• Reporter: Lianet Magrans
• Created: 12/Jun/23 18:37
• Updated: 04/Oct/23 16:53
• Resolved: 01/Sep/23 20:59

Description

Implement offsetForTimes for the kafka consumer based on the new threading model, using the OffsetsRequestManager. No changes at the consumer API level.

A call to the offsetsForTime consumer functionality should generate a ListOffsetsApplicationEvent with the timestamps to search provided in parameters. The ListOffsetsApplicationEvent is then handled by the OffsetsRequestManager, that builds the ListOffsets requests and processes the response when received.

Issue Links

• is part of: KAFKA-14246 Update threading model for Consumer
• requires: KAFKA-14965 Introduce OffsetsRequestManager to integrate ListOffsets requests into new consumer threading refactor