`kafkajs` API differences: `on`, `events`, `Partitioners`

[silverwind]

Following MIGRATION.md, I notice at least these differences from the kafkajs API which are not documented there. Feel free to close if you are not planning to implement a fully compatible API.

1. producer.on is absent (to register for producer events)
2. producer.events is absent (I'm using producer.events.CONNECT, producer.events.DISCONNECT, producer.events.REQUEST_TIMEOUT)
3. Partitioners export is absent (I'm using Partitioners.DefaultPartitioner)

[theo-bulfon-wmx]

Instrumentation Events were usefull.
I hope you will implement it.

consumer.on('consumer.group_join', () => {
   // DO SOMETHING
 });

Thank you for all the job done so far.

[troch]

Hello, I also use on('consumer.group_join') from KafkaJS to know when partition assignment has changed. There is consumer.assignment() to get assigned partitions, but I'd need to know when it changes. Thanks!

[Jamesgt]

A partial solution might be #287

[mfpereira]

Hello,

Anything about these differences?

I am migrating from KafkaJS to Confluentinc client and I used to capture these events to send notifications to my Slack channel when something gets wrong.

I used to have the follow lines in my code

consumer.on(consumer.events.CRASH, e => { Do something with CRASH event });
consumer.on(consumer.events.REQUEST_TIMEOUT, e => { Do something with REQUEST_TIMEOUT event });
consumer.on(consumer.events.GROUP_JOIN, e => { Do something with GROUP_JOIN event });
consumer.on(consumer.events.DISCONNECT, e => { Do something with DISCONNECT event });

And current documentation in INTRODUCTION has these lines

// Non-flowing mode
consumer.connect();

consumer
  .on('ready', () => {
    // Subscribe to the librdtesting-01 topic
    // This makes subsequent consumes read from that topic.
    consumer.subscribe(['librdtesting-01']);

    // Read up to 1000 message every 1000 milliseconds
    setInterval(() => {
      consumer.consume(1000);
    }, 1000);
  })
  .on('data', (data) => {
    console.log('Message found!  Contents below.');
    console.log(data.value.toString());
  });

But it doesnt work. The follow message is shown Error connecting consumer: KafkaJSError: Not implemented

[Forceres]

Any updates?

[bspec-natwest-roostermoney]

not gona lie but getting access to consumer.crash event would be nice