[jira] [Assigned] (KAFKA-16290) Investigate propagating subscription state updates via queues

["Kirk True (Jira)" <ji...@apache.org>]

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

Kirk True reassigned KAFKA-16290:
---------------------------------

    Assignee: Kirk True

> Investigate propagating subscription state updates via queues
> -------------------------------------------------------------
>
>                 Key: KAFKA-16290
>                 URL: https://issues.apache.org/jira/browse/KAFKA-16290
>             Project: Kafka
>          Issue Type: Task
>          Components: clients, consumer
>            Reporter: Lucas Brutschy
>            Assignee: Kirk True
>            Priority: Critical
>              Labels: kip-848
>             Fix For: 3.8.0
>
>
> We are mostly using the queues for interaction between application thread and background thread, but the subscription object is shared between the threads, and it is updated directly without going through the queues. 
> The way we allow updates to the subscription state from both threads is definitely not right, and will bring trouble. Places like the assign() is probably the most obvious, where we send an event to the background to commit, but then update the subscription in the foreground right away.
> It seems sensible to aim for having all updates to the subscription state in the background, triggered from the app thread via events (and I think we already have related events for all updates, just that the subscription state was left out in the app thread).



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