Print Rebalancing/Rebalanced Consumer Status

[teukuamru]

In kafka-node, I could do it like this

consumerGroup.on('rebalancing', () => {
  console.log('Consumer rebalancing...')
})

consumerGroup.on('rebalanced', () => {
  console.log('Consumer rebalanced!')
})

How can I achieve this in kafkajs?

[ankon]

There is a instrumentation event for when a consumer joined a group, which should be roughly matching the rebalanced state from your example: https://kafka.js.org/docs/instrumentation-events#consumer