librdkafka
librdkafka copied to clipboard
confluentinc
The Apache Kafka C/C++ library
Description =========== We're using the RPM packages from the Confluent repos. It appears that these packages are missing essential metadata. For example the packager information is missing and the changelog...
Read the FAQ first: https://github.com/edenhill/librdkafka/wiki/FAQ Do NOT create issues for questions, use the discussion forum: https://github.com/edenhill/librdkafka/discussions Description =========== 0x000000016bb7ab60 RdKafka::log_cb_trampoline(rd_kafka_s const*, int, char const*, char const*) 0x00000001043f3354 rd_kafka_log0 0x00000001047a9a18 rd_kafka_broker_bufq_timeout_scan...
Fixes #3927. Offset commit metadata can be used to send additional data to the broker when making an offset commit. See this [doc from the Java consumer](https://kafka.apache.org/21/javadoc/org/apache/kafka/clients/consumer/OffsetAndMetadata.html#:~:text=The%20Kafka%20offset%20commit%20API,the%20commit%20was%20made%2C%20etc.). Librdkafka currently sends...
Description =========== **THERE IS NO OBJECT LEAK** - program to re-create the issue attached here. RdKafka::Consumer destructor thread hangs due to broker thread rkb->rkb_refcnt being NOT zero. This happens during...
Description =========== **enable.idempotence=true** message.timeout.ms=30000 3 broker Kafka cluster used with topic replication factor=3 A continuous sequence(per topic partition) number is added to message body and as a header(to verify continuity)...
- KIP-339 Incremental Alter Configs Implementation. - Supporting Set, Remove, Append and Subtract Operations.
Remaining tasks: * Write changelog to outline the new behaviour with epochs, and what it fixes. Also mention the new ERR__LOG_TRUNCATION error code that will be raised if log truncation...
