[
https://issues.apache.org/jira/browse/KAFKA-15163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-15163:
-----------------------------------
Description:
Introduce support for validating positions in the new OffsetsRequestManager.
This task will include a new event for the validatePositions calls performed
from the new consumer, and the logic for handling such events in the
OffsetRequestManager.
The validate 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 VALIDATE_POSITIONS events that is submitted to the background thread, and the
processed by the ApplicationEventProcessor. The processing itself is done by
the OffsetRequestManager given that this will require an
OFFSET_FOR_LEADER_EPOCH request.
was:
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.
> Implement validatePositions functionality for new KafkaConsumer
> ---------------------------------------------------------------
>
> Key: KAFKA-15163
> URL: https://issues.apache.org/jira/browse/KAFKA-15163
> Project: Kafka
> Issue Type: Task
> Components: clients, consumer
> Reporter: Lianet Magrans
> Assignee: Lianet Magrans
> Priority: Major
> Labels: kip-945
>
> Introduce support for validating positions in the new OffsetsRequestManager.
> This task will include a new event for the validatePositions calls performed
> from the new consumer, and the logic for handling such events in the
> OffsetRequestManager.
> The validate 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 VALIDATE_POSITIONS events that is submitted to the background thread,
> and the processed by the ApplicationEventProcessor. The processing itself is
> done by the OffsetRequestManager given that this will require an
> OFFSET_FOR_LEADER_EPOCH request.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
