librdkafka
librdkafka copied to clipboard
confluentinc
The Apache Kafka C/C++ library
Description =========== We're using a KafkaConsumer object (not Legacy consumer) which is consuming from a single topic. The behaviour I'm about to describe happens regardless of whether the KafkaConsumer is...
Description =========== I am working on a Rtsp client project. In this project, my client code recieves data from mutiple Rtsp servers. I have a wrapper class. In the constructor...
Description =========== Now that librdkafka supports cooperative sticky partitions assignment strategy, we should ensure that consumers that commit offsets manually can’t commit offsets during rebalance as it triggers a follow...
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 =========== We are trying to use Kafka + kerbos authentication +GSSAPI for node...
Hello, I use the kafka version 1.9..2. rd_kafka_conf_set return error when it reads "sasl.jaas.config" config option. does sasl.jaas.config support by library ? any work around ? DH Read the FAQ...
As the new comment says: We shouldn't return NULL unless failure has actually occurred and our caller can proceed with cleaning up their resources. If librdkafka is still actively running...
We're hitting [this codepath](https://github.com/edenhill/librdkafka/blob/3b50e1e/src/rdkafka.c#L2512-L2537) in `rd_kafka_new`. This is in a pathologically large integration test where (1) all Kafka brokers are unreachable by design, and (2) we're running lots of VMs...
Port to IBM i OS400 The proposed changes are required to be able to build, test and use librdkafka on the native IBM i operating system - OS400. All necessary...
Description =========== I hava found a problem about 'rd_kafka_flush()', which can cause some data loss. The scenarios is: We use librdkafka to write record to KafkaCluster: ` resp_code = rd_kafka_produce*(...);...
