Bruno Cadonna created KAFKA-16285:
-------------------------------------

             Summary: Make group metadata available when a new assignment is 
set in async Kafka consumer
                 Key: KAFKA-16285
                 URL: https://issues.apache.org/jira/browse/KAFKA-16285
             Project: Kafka
          Issue Type: Improvement
          Components: clients, consumer
            Reporter: Bruno Cadonna


Currently, the new async Kafka consumer sends an event from the background 
thread to the application thread when the group metadata is updated. Group 
metadata is updated when the background thread receives a new assignment. More 
specifically, the member epoch is updated each time a new assignment is 
received and and the member ID is updated with the first assignment. 
In contrast to the group metadata update, the assignment is directly set in the 
subscription without sending an update event from the background thread to the 
application thread. That means that there is a delay between the application 
thread being aware of the update to the assignment and the application thread 
being aware of the update to the group metadata. This behavior differs with 
respect to the legacy consumer were the assignment and the group metadata is 
updated at the same time.
We should make the update to the group metadata available to the application 
thread when the update to the assignment is made available to the application 
thread so that assignment an group metadata are in sync.     



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

Reply via email to