Hi Chia-Ping Sorry for delay response!
Thank you very much for your feedback! One concern with relying on periodic scanning is that it may miss some rebalance event collection. In addition, a cluster can have hundreds of thousands of consumer groups, while in practice there may be no rebalance events in a whole day. This makes the scanning approach relatively inefficient and potentially wasteful. Ideally, a callback-based approach would be more suitable after all it is weight-light. . I understand there might be concerns about callbacks introducing blocking behavior into the system. However, this can be mitigated with a well-designed asynchronous callback mechanism and proper risk control by user. Thanks again for joining this discussion. Regards Jian Chia-Ping Tsai <[email protected]> 于2026年4月4日周六 16:48写道: > hi, > > If the goal is simply to collect the rebalance timing, using a broker-side > plugin feels a bit overkill. Alternatively, could we just expose the > assignmentTimestamp via the DescribeGroupsResponse? With this new field, > users could set up a cron job or monitor to poll the timestamp > periodically. While it might not cover 100% of real-time event tracking use > cases, it is much simpler and poses a significantly lower risk to the > server. > > Best, > Chia-Ping > > On 2026/04/04 07:44:29 jian fu wrote: > > Hi everyone, > > > > I would like to start a discussion for this small KIP. > > > > https://cwiki.apache.org/confluence/x/UZc8G > > > > Rebalance is the most important consumer event, and Kafka is moving > toward > > server-side rebalance. > > > > Today, client-side/sdk callbacks are useful but not always reliable > > operationally (SDK dependency, Not easy for central management). In > > incidents, key rebalance evidence is often missing on the client side.On > > the broker side, logs and metrics are still limited for automation: logs > > are hard to integrate reliably, and metrics do not include the most > > actionable key (group.id). > > > > This KIP proposes a lightweight broker-side callback to expose key > > rebalance context (including group.id) for centralized observability and > > automation, without forcing client upgrades and without adding > > high-cardinality metric tags. > > > > Your feedback is greatly appreciated. Thank you! > > > > Regards > > Jian > > >
