5f310d2b66
Default changes - socket.max.fails changed to 1 to provide same functionality (fail request immediately on error) now when retries are working properly again. - fetch.max.bytes (new config property) is automatically adjusted to be >= message.max.bytes, and receive.message.max.bytes is automatically adjusted to be > fetch.max.bytes. New features - Message Headers support - Java-compatible Murmur2 partitioners - Add PKCS#12 Keystore support - ssl.keystore.location Noteworthy fixes - Formalise and fix Producer retries and retry-ordering - Ordering is now retained despite retries if max.in.flight=1. - Behaviour is now documented - Fix timeouts for retried requests and properly handle retries for all request types - Add and use fetch.max.bytes to limit total Fetch response size. Fixes "Invalid response size" issues. Enhancements - Added sasl.mechanism and compression.type configuration property aliases for conformance with Java client. - Improved Producer performance - C++: add c_ptr() to Handle,Topic,Message classes to expose underlying librdkafka object - Honour per-message partition in produce_batch() if MSG_F_PARTITION set - Added on_request_sent() interceptor - Added experimental flexible producer queuing.strategy=fifo|lifo - Broker address DNS record round-robin: try to maintain round-robin position across resolve calls. - Set system thread name for internal librdkafka threads - Added more concise and user-friendly 'consumer' debug context - Add partitioner (string) topic configuration property to set the builtin partitioners - Generate rdkafka-static.pc (pkg-config) for static linking Fixes - Fix producer memory leak on <0.11 brokers when compressed messageset is below copy threshold - CRC32C - fix unaligned access on ARM - Fix read after free in buf_write_seek - Fix broker wake up - Fix consumer hang when rebalancing during commit - CMake fixes for Windows - LeaveGroup was not sent on close when doing final offset commits - Fix for consumer slowdown/stall on compacted topics where actual last offset < MsgSet.LastOffset - Fix global->topic conf fallthru in C++ API - Fix infinite loop on LeaveGroup failure - Fix possible crash on OffsetFetch retry - Incorporate compressed message count when deciding on fetch backoff - Fix debug-only crash on Solaris (%s NULL) - Drain broker ops queue on termination to avoid hang - cmake: Allow build static library - Don't store invalid offset as next one when pausing - use #if instead of #ifdef / defined() for atomics - fixed .lib paths in nuget packaging - Fixes strerror_r crash on alpine - Allow arbitrary lengthed (>255) SASL PLAIN user/pass - Trigger ApiVersionRequest on reconnect if broker.version.fallback supports it - Read Fetch MsgAttributes as int8 - Portability: stop using typeof in rdkafka_transport.c - Portability: replace use of #pragma once with header guards - mklove: add LIBS in reverse order to maintain dependency order - Fix build when python is not available #1358 |
||
|---|---|---|
| .. | ||
| patches | ||
| buildlink3.mk | ||
| DESCR | ||
| distinfo | ||
| Makefile | ||
| PLIST | ||