Milind L

It's already supported, by setting group.instance.id, for example: ``` const kafka = new Kafka({ kafkaJS: { brokers: [':9092'], ssl: true, sasl: { // ... }, } }); consumer = kafka.consumer({...

Thanks for filing this issue. I can't yet reproduce it locally, but we're seeing something like this in our CI intermittently. I'll investigate it further.

@nhr-one , if you can reproduce this issue consistently, could you turn on debug logs and attach them to the ticket? While I can sometimes reproduce this on CI or...

Hello @chayuto , thanks for reporting this. Are you setting the MessageFactory function on the deserializer, similar to this example? https://github.com/confluentinc/confluent-kafka-go/blob/50d6a03fc82c08a98891f9e19e02a1ff13ef74cb/schemaregistry/serde/avro/avro_generic_test.go#L105 If it isn't set, it's nil by default and...

Thanks for reporting this @patrykwegrzyn . I can see it. While we fix it, another potential workaround (with less work required for you), is to use `consumer.setDefaultIsTimeoutOnlyForFirstMessage(true)`. It will set...

There is no ordering for the operation you're describing. The 10 messages from the first 10 calls may be from any partition. The only thing that will be guaranteed will...

Hi, what is the platform this is being attempted on? Does it still occur? How as librdkafka installed, was it built from source?

Hey, is this still an issue with the latest version 2.5.0? Could you attach a backtrace of the segmentation fault? (By opening the dumped core with gdb and using `bt`...

I would suggest trying to use https://github.com/confluentinc/confluent-kafka-javascript which is compatible with node-rdkafka (and is based on it). It includes a precompiled version of librdkafka within which should have all the...

Thanks for the report. I could reproduce this intermittently (for me, it happens the first time I talk to a cluster with a group id which is not existing), but...