librdkafka icon indicating copy to clipboard operation
librdkafka copied to clipboard

The Apache Kafka C/C++ library

Results 477 librdkafka issues
Sort by recently updated
recently updated
newest added

### Description cross-compiling for target arm_cortex-a9_vfpv3 is failing ARCH:=arm BOARDNAME:=Marvell Armada 37x/38x/XP CPU_TYPE:=cortex-a9 **The actual error (more on the attached [build_librdkafka_error.txt](https://github.com/edenhill/librdkafka/files/6617850/build_librdkafka_error.txt))** ``` arm-openwrt-linux-muslgnueabi-gcc -MD -MP -g -O2 -fPIC -Wall -Wsign-compare...

portability

Kafka 2.7.0 included [KIP-554](https://cwiki.apache.org/confluence/display/KAFKA/KIP-554%3A+Add+Broker-side+SCRAM+Config+API), adding API support for managing SASL-SCRAM Users, improving the existing experience of registering credentials in Zookeeper via the `kafka-configs.sh` script. The Java Admin Client was also...

enhancement

Read the FAQ first: https://github.com/edenhill/librdkafka/wiki/FAQ Description =========== librdkafka requires a `group.id` for the `assign` operation of a consumer, while the Java client does not. https://github.com/edenhill/librdkafka/blob/f5c1045dc898abd1bd0b97da90b4717876f5d251/src/rdkafka_subscription.c#L110-L113 Java: https://github.com/apache/kafka/blob/1adb580faae89e0a298c0cb4ba08b238d91f9d03/clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java#L1101 Compared to "subscribe":...

While investigating issues around message size limits, we found that using `message.max.bytes` was necessary in the producer client to limit outgoing batch sizes, even though this is only [documented as...

Description =========== When using `ssl.certificate.pem` configuration the client doesn't send the full chain. **Note:** `ssl.certificate.location` sends the full chain How to reproduce ================ Run producer/consumer where `ssl.ca.location` has only the...

try reproduce

Description =========== Poor error text when producing messages, fails on MSG_SIZE_TOO_LARGE. Description points toward broker, when it is a client/producer error. The apache-kafka documentation for the kafka producer does not...

Cluster unavailable (eg network partition) for 15 minutes or so can put an idempotent producer into a state of excessive CPU usage. It can take several minutes after cluster restart...

GREAT REPORT

Coming from [here](https://gitter.im/edenhill/librdkafka?at=5f06fcbe8b72655b555efaf0) When consumers C1, C2 subscribing to non-existing topi, T (only one partition). Once the topic gets created, the metadata refresh happens in C1 first, rebalance cb is...

try reproduce

Read the FAQ first: https://github.com/edenhill/librdkafka/wiki/FAQ Description =========== I have just started looking at this library, and looking at the https://docs.confluent.io/current/clients/librdkafka/classRdKafka_1_1Producer.html#a540569ee0152703cdad4b45419f64b39 function, I see that the `RdKafka::Producer::create` function takes the conf...

Read the FAQ first: https://github.com/edenhill/librdkafka/wiki/FAQ Description =========== How is application supposed to use librdkafka to handle ssl certificate rotation scenario? How to reproduce ================ Below is the flow of events...

enhancement