librdkafka
librdkafka copied to clipboard
confluentinc
The Apache Kafka C/C++ library
Then, also in this branch: - rdkafkacpp: Remove an unused non-virtual function. The non-virtual function has the same name as a bunch of virtual functions, and so I'm guessing that...
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 =========== The c++ producer using librdkafka producing messages on a topic name and...
Description =========== Installing librdkafka on fedora 35 is currently failing. How to reproduce ================ Use the following commands to reproduce the issue: 1. First start the docker container ``` docker...
Description =========== we noticed a confluent-kafka python hang issue after a power outage of kafka brokers. How to reproduce ================ We reproduced this issue with the following steps: 1. Start...
Description =========== We've been chasing a segfault that sometimes occurs in the rdkafka Ruby gem when exiting: ``` /home/semaphore/rdkafka-ruby/lib/rdkafka/native_kafka.rb:44: [BUG] Segmentation fault at 0x00007f4f0dffb9d0 ruby 3.1.2p20 (2022-04-12 revision 4491bb740a) [x86_64-linux]...
I got an error of "no such configuration property" when I set conf of producer with properties of "buffer.memory" and "max.request.size" .My code: ----------------------------------------------------------------------------------------------- string errstr = ""; /* *...
In cases where a Windows producer spins up a new thread to produce a single message, the value emitted by rd_jitter is exactly the same for every new thread. On...
Also improves the documentation around this property. This solves the following problem: The property "allow.auto.create.topics" is supposed to be a consumer property, but we are setting it (and it is...
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 =========== I got a process hang with the librdkafka v1.8.2. I make some...
Attempting to make the max.poll.records a usable field, I know its available through the method call, however it would be useful to be able to call this method and have...
