[ https://issues.apache.org/jira/browse/KAFKA-14965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Lianet Magrans reassigned KAFKA-14965: -------------------------------------- Assignee: Lianet Magrans > Introduce ListOffsetsRequestManager to integrate ListOffsetsRequests into new > consumer threading refactor > --------------------------------------------------------------------------------------------------------- > > Key: KAFKA-14965 > URL: https://issues.apache.org/jira/browse/KAFKA-14965 > Project: Kafka > Issue Type: Task > Components: clients, consumer > Reporter: Lianet Magrans > Assignee: Lianet Magrans > Priority: Major > > This task introduces new functionality for handling ListOffsetsRequests for > the new consumer implementation, as part for the ongoing work for the > consumer threading model refactor. > This task introduces a new class named {{ListOffsetsRequestManager, > }}responsible of handling ListOffsets requests performed by the consumer to > expose functionality like beginningOffsets, endOffsets and offsetsForTimes. > The Offset{{{}Fetcher{}}} class is used internally by the {{KafkaConsumer}} > to list offsets, so this task will be based on a refactored > Offset{{{}Fetcher{}}}, reusing the fetching logic as much as possible. -- This message was sent by Atlassian Jira (v8.20.10#820010)