Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

New Broker Configuration

group.consumer.rebalance.listener.classes (LIST, default: empty)

  • A list of fully qualified class names implementing ConsumerGroupRebalanceListener.
  • Classes are instantiated and configured by the broker at startup.
  • Empty value means callback feature is disabled 

Proposed Changes

Add a lightweight broker-side callback path for consumer-group rebalance events, without changing client APIs and without adding high-cardinality metrics.

Server load the group.consumer.rebalance.listener.classes when startuping and trigger the callback interface when rebalance happened.

...