Lianet Magrans created KAFKA-14965: -------------------------------------- Summary: 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
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)