librdkafka
librdkafka copied to clipboard
confluentinc
The Apache Kafka C/C++ library
I have a project connecting to Confluent Kafka and SARAMA kafka both. The connection fails for Confluent kafka only with the below error: Failed to create Producer: No provider for...
Fixing 4 broken links in the documentation. 1. Statistics Schema JSON 2. transaction.c example file 3. rdkafka.h src file 4. rdkafka_ssl.c src file
Returning a `const string` means "My caller can have a copy of this string, but they aren't allowed to modify it" -- for example, they aren't allowed to use move...
No functional change intended; just cleaning up compiler warnings.
Description =========== generated `rdkafka-static.pc` is having wrong prefix: ``` prefix=/usr/local exec_prefix=${prefix} includedir=${prefix}/include libdir=${prefix}/lib Name: librdkafka++-static Description: The Apache Kafka C/C++ library (static) Version: 1.9.2 Requires: Cflags: -I${includedir} -DLIBRDKAFKA_STATICLIB Libs: -L${libdir}...
This PR adds a callback for obtaining the SASL PLAIN username and password. The use case here is to support changing the credentials to be used for a Kafka cluster...
Hi there, first things first: Thanks for the tremendous amount of work you are putting into librdkafka, @edenhill. You know who you are. ## Introduction This is not meant to...
librdkafka version: librdkafka-1.7.0 errormessage: ucer-3-retry: 0#producer-1: [rdkafka_buf.c:395]: [thrd:main]: TxnCoordinator/2: rkbuf: 0x7fd5bc0fea10, has msg: 0, retry: 1790, max retry: 1,lasterrcode=0[45776_] ^KafkaProducer.cpp:209^kafka_producer_logger|producer-3-ADDOFFSETS: 0#producer-1: [rdkafka_txnmgr.c:1922]: [thrd:main]: TxnCoordinator/2: Failed to add offsets to transaction...
windows10 上用vs2017编译librdkafka-master出现 fatal error C1083: 无法打开包括文件: “curl/curl.h”: No such file or directory fatal error C1083: 无法打开包括文件: “zstd.h”: No such file or directory
When decompressed batch sizes are big, e.g., `200MB`, the memory allocated for the buffer to store the decompressed batch sizes can become `600MB` based on this buffer growth formular: `out_bufsize...
