[jira] [Updated] (KAFKA-14965) Introduce OffsetsRequestManager to integrate ListOffsets requests into new consumer threading refactor
[ https://issues.apache.org/jira/browse/KAFKA-14965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-14965: -- Parent: KAFKA-14246 Issue Type: Sub-task (was: Task) > Introduce OffsetsRequestManager to integrate ListOffsets requests into new > consumer threading refactor > -- > > Key: KAFKA-14965 > URL: https://issues.apache.org/jira/browse/KAFKA-14965 > Project: Kafka > Issue Type: Sub-task > Components: clients, consumer >Reporter: Lianet Magrans >Assignee: Lianet Magrans >Priority: Major > Labels: consumer-threading-refactor > Fix For: 3.7.0 > > > This task introduces new functionality for handling ListOffsets requests for > the new consumer implementation, as part for the ongoing work for the > consumer threading model refactor. > This task introduces a new class named \{{OffsetsRequestManager, > }}responsible of : > * building ListOffsets requests > * process its responses > Consumer API functionality that requires ListOffsets requests are implemented > using this manager: beginningOffsets, endOffsets and offsetsForTimes. > These consumer API functions will generate a ListOffsetsApplicationEvent with > parameters. This event is then handled by the OffsetsRequestManager, who will > build the ListOffsets request and process its responses, to provide a result > back to the API via the ListOffsetsApplicationEvent completion. -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Updated] (KAFKA-14965) Introduce OffsetsRequestManager to integrate ListOffsets requests into new consumer threading refactor
[ https://issues.apache.org/jira/browse/KAFKA-14965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lianet Magrans updated KAFKA-14965: --- Description: This task introduces new functionality for handling ListOffsets requests for the new consumer implementation, as part for the ongoing work for the consumer threading model refactor. This task introduces a new class named \{{OffsetsRequestManager, }}responsible of : * building ListOffsets requests * process its responses Consumer API functionality that requires ListOffsets requests are implemented using this manager: beginningOffsets, endOffsets and offsetsForTimes. These consumer API functions will generate a ListOffsetsApplicationEvent with parameters. This event is then handled by the OffsetsRequestManager, who will build the ListOffsets request and process its responses, to provide a result back to the API via the ListOffsetsApplicationEvent completion. was: 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. > Introduce OffsetsRequestManager to integrate ListOffsets requests 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 > Labels: consumer-threading-refactor > > This task introduces new functionality for handling ListOffsets requests for > the new consumer implementation, as part for the ongoing work for the > consumer threading model refactor. > This task introduces a new class named \{{OffsetsRequestManager, > }}responsible of : > * building ListOffsets requests > * process its responses > Consumer API functionality that requires ListOffsets requests are implemented > using this manager: beginningOffsets, endOffsets and offsetsForTimes. > These consumer API functions will generate a ListOffsetsApplicationEvent with > parameters. This event is then handled by the OffsetsRequestManager, who will > build the ListOffsets request and process its responses, to provide a result > back to the API via the ListOffsetsApplicationEvent completion. -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Updated] (KAFKA-14965) Introduce OffsetsRequestManager to integrate ListOffsets requests into new consumer threading refactor
[ https://issues.apache.org/jira/browse/KAFKA-14965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lianet Magrans updated KAFKA-14965: --- Summary: Introduce OffsetsRequestManager to integrate ListOffsets requests into new consumer threading refactor (was: Introduce ListOffsetsRequestManager to integrate ListOffsetsRequests into new consumer threading refactor) > Introduce OffsetsRequestManager to integrate ListOffsets requests 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 > Labels: consumer-threading-refactor > > 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)