librdkafka
librdkafka copied to clipboard
confluentinc
The Apache Kafka C/C++ library
Reading the documentation, specifically this part: https://github.com/confluentinc/librdkafka/blob/master/INTRODUCTION.md#error-handling-1 I'm a bit confused about the meaning of what is meant by "set" in that part of the documentation: > For all other...
Description =========== librdkafka uses OpenSSL 3 prior to 3.0.8 which is vulnerable: [CVE-2023-0286] - https://nvd.nist.gov/vuln/detail/CVE-2023-0286/ [CVE-2022-4450] - https://nvd.nist.gov/vuln/detail/CVE-2022-4450/ [CVE-2023-0215] - https://nvd.nist.gov/vuln/detail/CVE-2023-0215/ How to reproduce ================ No need, vulnerable libraries are...
### Description Pseudo c++ code ``` rd_kafka_conf_set(conf, "bootstrap.servers", "xxx.xxx.xxx.01:9092,xxx.xxx.xxx.02:9092,xxx.xxx.xxx.03:9092,xxx.xxx.xxx.04:9092,xxx.xxx.xxx.05:9092"); rd_kafka_conf_set(conf, "transactional.id", "librdkafka_transactions_example"); rd_kafka_conf_set_dr_msg_cb(conf, dr_msg_cb); producer = rd_kafka_new(RD_KAFKA_PRODUCER, conf, errstr, sizeof(errstr)); rd_kafka_init_transactions(producer, -1); // q1: 3 partitions + 5 replicas auto...
Brokers that are not in the metadata should be purged from the internal client lists. This helps to avoid annoying "No route to host" and other connection failure messages. Fixes...
Description =========== We have found that an offset was committed before we have called commit on the consumer group. We have auto offset storing enabled and auto commit disabled. We...
### Updated metrics matching Created a new field `temporality` which is used for matching metrics. Uses https://github.com/confluentinc/librdkafka/pull/4516 as the base. ### Pending bug fixes: 1. Handling if the broker updates...
Built on top of https://github.com/confluentinc/librdkafka/pull/4515 Updates metric matching logic to send gauge metrics always.