Aaron Peloquin

Can you confirm that `await producer.send({...})` will throw an error if message/batch is not received per the `acks` value, as in KafkaJS? In our scenario, our app has tracking that...

Re-running with lingerMs: 0 definitely puts the message production on the fast track. I'm wondering if there is a similar optimization that can be made on the consumer side. With...

Understood. It appears that KafkaJS handles this by loading metadata for _all_ topics at the time the producer is connected, not on-demand when the message is sent. For our case,...

Hi @milindl, > There is a workaround for it within the underlying library, I will work to make it accessible from the Javascript binding, and discuss with my team if...

When I do a diff of the `node_modules/@confluentinc/kafka-javascript/build/Release/` directories before/after running the `node-pre-gyp` on the started container, the noticeable difference is many instances of: * `/home/semaphore/.cache` replaced with `/root/.cache` *...

Hi @milindl, we are already using client ID when creating the Kafka class instances. However, when that same class is used to create dozens of consumers for different topics this...

Missing `index.d.ts` as well. ```bash $ npm i --save-exact @confluentinc/[email protected] ... $ tree node_modules/\@confluentinc/schemaregistry/ -L 2 node_modules/@confluentinc/schemaregistry/ ├── dist │ ├── confluent │ ├── e2e │ ├── google │ ├──...