Milind L

Hi @sgajjarhawk, Right now, indeed the only thing you can do is destroying, and then recreating your producer whenever you encounter a fatal error like this one, since a fatal...

Thanks for the PR. The intent of this is to allow number or nulls to be passed onto the produce headers. Is that correct? Two things: 1. Could you update...

Thanks for the PR update. I've been thinking about the conversion thing. The Kafka protocol expects header values to be []bytes. Breaking a number into bytes might pose a slight...

Added: ListGroups to list consumer groups

Added: DeleteGroups and DescribeGroups Added: ListTopics

@brunodomenici , the function is already available in the released version of the library which you can download off npm. Unfortunately I've not added an example yet, but the usage...

The eslint fails, as expected, but on the whole, some sort of a build flow is actually working. I'll keep adding more stuff to this PR

Thanks a lot for filing this issue! I took a look, I saw where the problem is. Results on my machine with identical code (Ubuntu on WSL), running a single...

Details of the issue: Once a produce request is sent, librdkafka delivers the delivery-report on a poll basis. Internally the Confluent library calls this polling function with setInterval. When producer.send()...

I've merged a change within the code to fix this flow, and added guidelines in the MIGRATION.md file as well. For maintaining parity with librdkafka, the parameter 'linger.ms' has the...