librdkafka
librdkafka copied to clipboard
The Apache Kafka C/C++ library
OpenSSL can be built without ENGINE support, and some libssl-compatible forks (e.g. BoringSSL) don't contain any ENGINE implementation at all - guard all references to the ENGINE API using `OPENSSL_NO_ENGINE`...
Description =========== Timer scheduling is O(n^2) in the number of timers (under a reasonable assumption about the interval distribution). How to reproduce ================ Consume from any topic with 20k partitions...
This PR fixes out-of-bounds memory accesses in regex parsing found by OSS-Fuzz. # Out-of-bounds write The implicit casting from integer to unsigned char of min & max in `parserep` allowed...
Add API to replace rd_kafka's default allocator with a custom implementation
Description =========== EDITED 12/30/2021: The origin of the weird exception was identified and corrected. However, there still appears to be a triggerable deadlock with the new flush implementation, at least...
Description =========== I am trying to consume topic's using regex `^nginx.(?!svc$|nginx$|.*sandbox).*` and getting `Local: Invalid argument or configuration (invalid_arg)`. How could I solve this issue? And seems I was not...
### Discussed in https://github.com/edenhill/librdkafka/discussions/3823 Originally posted by **garishach** April 21, 2022 While producer.cpp compiled successfully, when compiling rdkafka_complex_consumer_example.cpp, #include header included, shows the following errors: `g++ rdkafka_complex_consumer_example.cpp -lrdkafka++ rdkafka_complex_consumer_example.cpp: In...
Description =========== When certificates for the Kafka brokers are signed with a custom CA, it is required that the signing CA is the first with the same CN in a...
librdkafka currently ignores (application) commit requests if the offsets match that of the last known commit. For reasons stated [here](https://github.com/confluentinc/confluent-kafka-python/issues/118#issuecomment-293139534) (commit expiry is shorter than message interval) it is desired...
This is a coalescing issue for the following common issues: - Too many connections to broker (connections maintained even though they are unused) ✅ - Too many threads (causes CPU...