KIP-566 — Add rebalance callbacks to ConsumerInterceptor

Discussion Consumer

Extends ConsumerInterceptor to also implement ConsumerRebalanceListener, adding onPartitionsRevoked/onPartitionsAssigned callbacks to the interceptor lifecycle. Without this, interceptors that maintain per-partition state (e.g., for metrics or tracing) have no way to clean up or reinitialize state when partitions are reassigned.

Details