Milind L

Description =========== delivery.report.only.error: true -> fails with expected error delivery.report.only.error: "true" -> no failure message and is passed to librdkafka. it's a memory leak to do this.

Bump version of confluentinc/confluent-kafka-go

3

Test PR for checking windows build on semaphore while updating confluent-kafka-go to 2.3.0

* store() - done * setting sasl credentials dynamically - done * subscriptions() * epoch related fields on partitions - as in v2.1.0 of librdkafka - done * metadata commit...

Add admin API operations to promisified and non-promisified API

6

For example: listing topics, ACL operations, consumer group operations, consumer group offset operations.

Add consumer errors and clean up consumer code

1

Contains changes and error handling for the consumer. --- We might need to take a deeper dive into seeing how auto-commit is handled, as well as multiple eachMessage's dispatched at...

Segfault while closing the consumer while consume loop is running

2

Reproduction code: ``` function runConsumer() { const consumer = new RdKafka.KafkaConsumer({ 'group.id': 'test-group' + Math.random(), 'bootstrap.servers': 'localhost:9092', }, { 'auto.offset.reset': 'earliest', }); consumer.connect(); consumer.on('ready', () => { console.log("Consumer is ready");...

The change to the run() method is because await run() is expected not to block an async method as per the api.

Adds test helpers and jest as well. Also, while adding the tests, I found several missing things, or bugs. Those are fixed, too. Each commit contains a specific test file,...