ConsumerGroupStream does not relay events from ConsumerGroup

[aikar]

Questions?

• Check the Troubleshooting / FAQ ?
• Search the issues ?

Bug Report

Events emitted on the inner consumerGroup instance are not being relayed to the ConsumerGroupStream

This breaks the ability to do consumer.on('connect', () => {}); for example.

It requires you to do consumer.consumerGroup.on('connect') instead.

I suggest events emitted should proxy to the ConsumerGroupStream.

Environment

• Node version: 8.9.x
• Kafka-node version: 2.3.0
• Kafka version: 0.11

Example:

        consumer.on('rebalancing', () => {
            if (this._consumerReady.resolved) {
                this._consumerReady = resolvable();
            }
            this.logger.info("Rebalancing");
            this.emit("kafka:rebalance");
        });

        consumer.on('connect', () => { });

[flejz]

Probably because options.connectOnReady is hardcoded to false in ConsumerGroupStream, ignoring the default from the ConsumerGroup instance and the options.

Set manually to true (for testing purpose only) worked for me.