You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Lianet Magrans (Jira)" <ji...@apache.org> on 2023/06/22 18:41:00 UTC
[jira] [Created] (KAFKA-15115) Implement resetPositions functionality in ListOffsetRequestManager
Lianet Magrans created KAFKA-15115:
--------------------------------------
Summary: Implement resetPositions functionality in ListOffsetRequestManager
Key: KAFKA-15115
URL: https://issues.apache.org/jira/browse/KAFKA-15115
Project: Kafka
Issue Type: Task
Components: clients, consumer
Reporter: Lianet Magrans
Assignee: Lianet Magrans
Introduce support for resetting positions in the new ListOffsetsRequestManager. 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 ListOffsetRequestManager.
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 the processed by the ApplicationEventProcessor. The processing itself is done by the ListOffsetRequestManager given that this will require a LIST_OFFSETS request for the partitions awaiting reset.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)