You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Lianet Magrans (Jira)" <ji...@apache.org> on 2023/10/04 13:52:00 UTC

[jira] [Resolved] (KAFKA-15164) Extract reusable logic from OffsetsForLeaderEpochClient

     [ https://issues.apache.org/jira/browse/KAFKA-15164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Lianet Magrans resolved KAFKA-15164.
------------------------------------
    Resolution: Fixed

Included in PR https://github.com/apache/kafka/pull/14346

> Extract reusable logic from OffsetsForLeaderEpochClient
> -------------------------------------------------------
>
>                 Key: KAFKA-15164
>                 URL: https://issues.apache.org/jira/browse/KAFKA-15164
>             Project: Kafka
>          Issue Type: Task
>          Components: clients, consumer
>            Reporter: Lianet Magrans
>            Assignee: Lianet Magrans
>            Priority: Major
>              Labels: consumer-threading-refactor
>
> The OffsetsForLeaderEpochClient class is used for making asynchronous requests to the OffsetsForLeaderEpoch API. It encapsulates the logic for:
>  * preparing the requests
>  * sending them over the network using the network client
>  * handling the response
> The new KafkaConsumer implementation, based on a new threading model, requires the same logic for preparing the requests and handling the responses, with different behaviour for how the request is actually sent.
> This task includes refactoring OffsetsForLeaderEpochClient by extracting out the logic for preparing the requests and handling the responses. No changes in the existing logic, just making the functionality available to be reused.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)