librdkafka

librdkafka copied to clipboard

Hello, I am using the lbrdkafka (Confluent.Kafka 2.5.2) libraries to connect to a kafka cluster. however the kafka cluster we are attempting to connect to has configured an oidc authentication...

edriscoll-softheon

Fix checking SASLHandshake from APIVersions

1

`librdkafka`'s current (SASL) authentication behavior: 1. It sends an `APIVersions` request and sets `RD_KAFKA_FEATURE_SASL_HANDSHAKE` if the supported versions of [`SASLHandshake` from server overlap with `[0, 0]`](https://github.com/confluentinc/librdkafka/blob/93877617709eb071a0f4ec7038c54e2764abefc9/src/rdkafka_feature.c#L159). 2. If not set,...

oliversun9

[https://github.com/confluentinc/confluent-kafka-python/issues/1934](url)

narasimha-reddy-kr

fix include for pthread_set_name_np on freebsd

1

``` Feb 27 21:33:43 FAILED: contrib/librdkafka-cmake/CMakeFiles/_rdkafka.dir/__/librdkafka/src/tinycthread_extra.c.o Feb 27 21:33:43 /usr/bin/sccache /usr/bin/clang-19 --target=x86_64-pc-freebsd11 --sysroot=/build/cmake/freebsd/../../contrib/sysroot/freebsd-x86_64 -DCJSON_HIDE_SYMBOLS -DLZ4_FAST_DEC_LOOP=1 -DSTD_EXCEPTION_HAS_STACK_TRACE=1 -DUNALIGNED_OK -DWITH_GZFILEOP -DX86_64 -DZLIB_COMPAT -D_LIBCPP_ENABLE_THREAD_SAFETY_ANNOTATIONS -D_LIBUNWIND_IS_NATIVE_ONLY -D_WITH_DPRINTF -Dcall_once=rd_kafka_call_once -Dcnd_broadcast=rd_kafka_cnd_broadcast -Dcnd_destroy=rd_kafka_cnd_destroy -Dcnd_init=rd_kafka_cnd_init -Dcnd_signal=rd_kafka_cnd_signal -Dcnd_timedwait=rd_kafka_cnd_timedwait -Dcnd_wait=rd_kafka_cnd_wait...

filimonov

Cannot consume when a topic has more than 3 partitions: "Broker: Not coordinator" error

4

I am not sure whether this is a librdkafka issue or a Kafka issue but (1) I'm using the default server.properties file from Kafka and (2) everything works fine when...

mdorier

"Local: Message timed out" and message loss

1

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 =========== When using `enable.idempotence=true` , I get this error occasionally (typically 10k incidents....

alexec

Need to understand the pattern for interal Queue ?

1

I have been using kafka since 2017 and have been used librb c++ kafka lib since that time itself ... Our produce rate on Kafka is like 3K -3.5k per...

abhit011