librdkafka

librdkafka copied to clipboard

Combine message timeout drain bumps

1

Amend idempotent producer message timeout handling from #2163 in relation to CPU usage issue #3692 Issue an idempotent producer drain-bump only once per entire scanning cycle rather than for each...

larry-cdn77

Currently, certificate are only read on the creation of a client. That means that if the cert changes during the lifetime of the client connection, the client will now have...

vctoriawu

Crash in rd_kafka_flush() if the connection is TLS.

1

Read the FAQ first: https://github.com/edenhill/librdkafka/wiki/FAQ Description =========== Precondition: Kafka Broker is down. If the connection is over TCP then it's working as expected, but if we use TLS then it's...

Animesh-ctrl

Consider supporting per-socket TCP Keep-Alive settings: `TCP_KEEPIDLE`, `TCP_KEEPINTVL`, `TCP_KEEPCNT`

3

# Description First of all, thanks for the existing support of TCP Keep-Alive through the `socket.keepalive.enable` configuration. I am in a similar position to those here: https://github.com/edenhill/librdkafka/issues/3109, and I'm struggling...

nickwb

Separate partition queues no longer working in v1.6.0

7

Description =========== We're seeing test failures in Materialize with librdkafka v1.6.0 that weren't present in v1.5.3 regarding split partition queues. Basically, we want _n_ different queues to poll given a...

benesch

RdKafka::Producer parses aws kafka broker reporting segment errors when the cluster information is retrieved after a few minutes

4

The rdkafka library gave an error in resolving the aws kafka broker address when the cluster information is retrieved after a few minutes. And pulling the latest version of rdkafka...

yxuechao007

Try multiple brokers for InitProducerIdRequest

1

See https://github.com/confluentinc/confluent-kafka-python/issues/1335

edenhill

assignor: API for a custom consumer group assignment strategy

4

This addresses https://github.com/edenhill/librdkafka/issues/2284 Exported API is sufficient enough to implement existing assignment strategies and allow users define their own. This PR does not change how rebalance works, it reworks existing...

niamster

Description =========== The current NuGet package does not include arm64-windows artifacts. The library builds fine for arm64-windows (tested using vcpkg). Checklist ========= - [x] librdkafka version (release number or git...

pragmanomos

[Feature request] Vectored I/O for producer

6

Please consider adding something like `writev()` to producer functions. In my application I have messages that consist of segments (this allows me to use fast pool allocator). Before calling `produce()`...

viccpp