Emanuele Sabellico
Emanuele Sabellico
Yeah, the `hdrs `variable should be set to NULL before [rd_kafka_msg_destroy](https://github.com/confluentinc/librdkafka/blob/267367c9475c2154e72eafe6ff1957518cb2ed1a/src/rdkafka_msg.c#L505) if it corresponds to the message headers, otherwise it's freed a second time [here](https://github.com/confluentinc/librdkafka/blob/267367c9475c2154e72eafe6ff1957518cb2ed1a/src/rdkafka_msg.c#L521)
Hello, we have an [example ](https://github.com/confluentinc/confluent-kafka-python/blob/master/examples/asyncio_example.py) using asyncio. You have to use a different thread to poll (producer/consumer) or consume (consumer) and make sure all the callbacks, are wrapped with...
There is a problem in v2.3.0 when metadata is refreshed without leader changes that avoids that fast metadata refresh is stopped. We'll include this fix in next release.
/sem-approve
@nhaq-confluent what @mensfeld proposed is a workaround, but we have to review and merge this PR I created https://github.com/confluentinc/librdkafka/pull/4528
Thanks Anchit, please add this to CHANGELOG ``` # 2.4.0 ## Enhancements - References librdkafka.redist 2.4.0. Refer to the [librdkafka v2.4.0 release notes](https://github.com/confluentinc/librdkafka/releases/tag/v2.4.0) for more information. ``` And change these...
@anchitj we can keep the CHANGELOG in sync with the code we merge, that is a work in progress too until we release. They will know it's a RC if...
@Quuxplusone thanks for the description of the problem. Will try to reproduce it, maybe it's linked to stopping and restarting the broker. Could you try it without `rd_kafka_conf_set_rebalance_cb` to see...
Some issues that could be related https://github.com/confluentinc/librdkafka/issues/4519 https://github.com/confluentinc/librdkafka/issues/4131 https://github.com/confluentinc/librdkafka/issues/3954
@Quuxplusone could you verify these things? - if it does happen calling only `rd_kafka_destroy` without closing the consumer first. That will close the consumer too, but after setting a flag....