librdkafka
librdkafka copied to clipboard
confluentinc
The Apache Kafka C/C++ library
Description =========== Offset commit metadata can be used to send additional data to the broker when making an offset commit. See this [doc from the Java consumer](https://kafka.apache.org/21/javadoc/org/apache/kafka/clients/consumer/OffsetAndMetadata.html#:~:text=The%20Kafka%20offset%20commit%20API,the%20commit%20was%20made%2C%20etc.). Librdkafka currently sends...
This is a follow-up based on the modifications done in [PR #2546](https://github.com/edenhill/librdkafka/pull/2546) . Added handling of SSLKEYLOGFILE environment variable to write the TLS session keys in the same way e.g....
Description =========== When the broker endpoints are the same with different broker ids. the client thinks that a topic is changing broker ids when it overrides records of the same...
Description: We are intermittently getting following error while consuming kakfa atopic *** rdkafka_partition.c:364:rd_kafka_toppar_set_fetch_state: assert: thrd_is_current(rktp->rktp_rkt->rkt_rk->rk_thread) *** Once we get above error the application crashes. **Kafka Topic configuration** Partition Count =...
Description =========== I believe librdkafka might not work with confluent's kafka brokers because you must have a truststore/keystore setup, which librdkafka does not have a truststore option (although it has...
Description =========== I have implemented the cooporative rebalance in node-rdkafka and when i first started, the e2e tests were working. Soon I realized that they don't alway run trough. Sporadically...
Description =========== when set enable.auto.commit as false, manually commit the received messages, the consumer lag keeps to be 1 , it seems like the transaction control message is not commited,...
Description =========== Using .NET Confluent.Kafka 1.9.0 which is using librdkafka 1.9.0 resulted in having 2 dependent libraries using versions which have Vulnerabilities (CVEs): 1. librdkafka is using OpenSSL version 1.1.1n...
Description =========== I am using partition queues and kept seeing application hanging on destructors. Seen similar issues #3007 and #3143 but i could reproduce on 1.7.0. Then created minimal test....
