You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "A. Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2021/12/14 01:18:00 UTC
[jira] [Created] (KAFKA-13542) Utilize the new Consumer#enforceRebalance(reason) API in Streams
A. Sophie Blee-Goldman created KAFKA-13542:
----------------------------------------------
Summary: 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
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)