librdkafka
librdkafka copied to clipboard
The Apache Kafka C/C++ library
Fix double free as reported by address sanitize that causes a crash when deleting the memory a second time if it is already being used between the deletes. Easily reproduced...
e.g. fluent-bit is a c-only library, so allow compilation without cxx - Issue: #4364 - Logs: http://autobuild.buildroot.org/?reason=fluent-bit-2.1.7
This is a very poor attempt at addressing the issue mentioned here: https://github.com/confluentinc/librdkafka/issues/4348, which is caused by https://github.com/openssl/openssl/issues/11560#issuecomment-1619143823 If this is the wrong place to be attempting to address the...
Taken common structs from https://github.com/confluentinc/librdkafka/pull/4609/files.
We have Kafka configured on production server with topics created. Sometimes during the deploy when Kafka was down for a while some apps are not able to make query. The...
Description =========== ``` Program terminated with signal SIGABRT, Aborted. #0 0x00007fe12277026c in ?? () from /usr/lib/libc.so.6 [Current thread is 1 (Thread 0x7fe1221e3440 (LWP 1678161))] (gdb) bt #0 0x00007fe12277026c in ??...
### Discussed in https://github.com/confluentinc/librdkafka/discussions/4333 Originally posted by **vdeters** June 27, 2023 Using the C++ Producer api (version 2.1.1), I see one produce() method that supports passing a RdKafka::Headers pointer, but...
Store the assigned topic partition offsets in a async commit when they haven't been explicitly supplied to avoid a race condition with other consume calls. More details of the issue...