[KAFKA-15115] Implement resetPositions functionality in OffsetsRequestManager

• 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: 22/Jun/23 18:40
• Updated: 20/Oct/23 00:38
• Resolved: 13/Sep/23 14:51

Description

Introduce support for resetting positions in the new OffsetsRequestManager. This task will include a new event for the resetPositions calls performed from the new consumer, and the logic for handling such events in the OffsetRequestManager.

The reset positions implementation will keep the same behaviour as the one in the old consumer, but adapted to the new threading model. So it is based in a RESET_POSITIONS events that is submitted to the background thread, and then processed by the ApplicationEventProcessor. The processing itself is done by the OffsetRequestManager given that this will require a LIST_OFFSETS request for the partitions awaiting reset.

Issue Links

• is cloned by: KAFKA-15163 Implement validatePositions functionality for new KafkaConsumer
• is part of: KAFKA-14246 Update threading model for Consumer
• links to: GitHub Pull Request #14346