producer.produce should be a promise

[fberrez]

Environment Information

• node-rdkafka version: 3.1.0

Steps to Reproduce

const { Producer } = require('node-rdkafka');

async function produce() {
  const producer = new Producer({
    'client.id': 'client-id',
    'metadata.broker.list': 'localhost:9092',
  });
  await producer.connect();
  // ...wait for readiness
  producer.produce('local.ssh-sender', null, Buffer.from('Hello Kafka!'), 'key', Date.now());
  process.exit(0)
}

produce();

Additional context

This code will never send the message in the kafka queue because producer.produce is not a promise so process.exit will be executed (almost) at the same time

[aferrando-tid]

While it's true that it would be a nice to have produce returning a promise, it also accepts a callback. You can wrap the call in a new Promise and then you can await on it.