[
https://issues.apache.org/jira/browse/KAFKA-13542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman reopened KAFKA-13542:
--------------------------------------------
Reopening this since it was reverted pending investigation into a benchmark
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)
