librdkafka
librdkafka copied to clipboard
confluentinc
The Apache Kafka C/C++ library
Description =========== This might be related to the same problem as in #3663 but on a different API call. I am trying to simply scrape my Kafka cluster with the...
Description =========== When scaling down a replica count from 5 to 4 as an instance, there is a 60s disconnection until the consumer start reading messages back from one of...
Addresses https://github.com/confluentinc/librdkafka/issues/4522 rd_atomic32_set instead of rd_atomic32_init in rd_kafka_bufq_init
i installed librkafka (2.2.0) by brew and iimplement with swift 5 i need send message to topic with **headers** attach in **producer** but i cannot use func **rd_kafka_producev** although i...
Description =========== Building librdkafka from source on either OracleLinux or AmazonLinux is failing. It works fine on RHEL (UBI) but not on the derivative distributions OracleLinux or AmazonLinux. How to...
Description =========== ``` WARNING: ThreadSanitizer: data race (pid=1) Atomic write of size 4 at 0x7b78000f4bb0 by thread T377 (mutexes: read M0, write M1): #0 rd_atomic32_get build_docker/./contrib/librdkafka/src/rdatomic.h:108:9 (clickhouse+0x1f8b1a93) (BuildId: 662ff0bfd164437162d27a08d006d6ba54fefcf7) #1...
Merges master with the 714 branch and also merges the following remaining PRs: 1. https://github.com/confluentinc/librdkafka/pull/4473 2. https://github.com/confluentinc/librdkafka/pull/4488 3. https://github.com/confluentinc/librdkafka/pull/4515 4. https://github.com/confluentinc/librdkafka/pull/4516 5. https://github.com/confluentinc/librdkafka/pull/4529 https://github.com/confluentinc/librdkafka/pull/4441 is also included with necessary changes...
After KIP-580, this property is used for both consumer and producer related operations, sort of as a general backoff. The configuration needs to be updated to reflect this, else we...
Description =========== Consumer in cooperative incremental mode will hang if an assignment callback is being processed while it's closing. How to reproduce ================ Added a variation 3 to test 0113...
Description =========== I found that if I create a TopicPartition, and set its offset, the consumer still consume from the latest offset. I read from FAQ, it say "This API...
