Consumer inside KafkaPubSub class is private

[gnpace]

The consumer inside the KafkaPubSub class is private.

I need to access it in order to register it to some emitted events like "consumer.stop" or "consumer.crash".

Can you please provide a solution for this?

Maybe a public method inside the KafkaPubSub class that allows registering events to the created consumer could be a solution?

Thanks!

[gnpace]

@tomasAlabes something like this could be a solution?

import {
  ...
  ConsumerEvents
  RemoveInstrumentationEventListener,
  ValueOf
} from "kafkajs";

...

public consumerOn(
  eventName: ValueOf<ConsumerEvents>,
  listener: (event: any) => void
): RemoveInstrumentationEventListener<typeof eventName> {
  return this.consumer.on(eventName, listener);
}

[tomasAlabes]

Would you mind create a PR for the proposal? I don't mind taking a look and adding it.