[ 
https://issues.apache.org/jira/browse/KAFKA-13542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17511537#comment-17511537
 ] 

Matthias J. Sax commented on KAFKA-13542:
-----------------------------------------

Curious: did we figure out why the patch resulted in the perf regression?

> Utilize the new Consumer#enforceRebalance(reason) API in Streams
> ----------------------------------------------------------------
>
>                 Key: KAFKA-13542
>                 URL: https://issues.apache.org/jira/browse/KAFKA-13542
>             Project: Kafka
>          Issue Type: Task
>          Components: streams
>            Reporter: A. Sophie Blee-Goldman
>            Assignee: Hao Li
>            Priority: Blocker
>             Fix For: 3.2.0
>
>
> KIP-800 is adding a new "reason" parameter to the Consumer#enforceRebalance 
> API, which will be passed in to a new field of the JoinGroup protocol. We 
> invoke this API throughout Streams for various reasons, which are very useful 
> for debugging the cause of rebalancing. Passing in the reason to this new API 
> would make it possible to figure out why a Streams client triggered a 
> rebalance from the broker logs, which are often the only logs available when 
> the client logs cannot be retrieved for whatever reason



--
This message was sent by Atlassian Jira
(v8.20.1#820001)

Reply via email to