v2.1.1
版本发布时间: 2023-05-03 06:11:28
confluentinc/librdkafka最新发布版本:v2.5.3(2024-09-02 22:32:10)
librdkafka v2.1.1 is a maintenance release:
- Avoid duplicate messages when a fetch response is received in the middle of an offset validation request (#4261).
- Fix segmentation fault when subscribing to a non-existent topic and
calling
rd_kafka_message_leader_epoch()
on the polledrkmessage
(#4245). - Fix a segmentation fault when fetching from follower and the partition lease expires while waiting for the result of a list offsets operation (#4254).
- Fix documentation for the admin request timeout, incorrectly stating -1 for infinite timeout. That timeout can't be infinite.
- Fix CMake pkg-config cURL require and use
pkg-config
Requires.private
field (@FantasqueX, @stertingen, #4180). - Fixes certain cases where polling would not keep the consumer in the group or make it rejoin it (#4256).
- Fix to the C++ set_leader_epoch method of TopicPartitionImpl, that wasn't storing the passed value (@pavel-pimenov, #4267).
Fixes
Consumer fixes
- Duplicate messages can be emitted when a fetch response is received in the middle of an offset validation request. Solved by avoiding a restart from last application offset when offset validation succeeds.
- When fetching from follower, if the partition lease expires after 5 minutes,
and a list offsets operation was requested to retrieve the earliest
or latest offset, it resulted in segmentation fault. This was fixed by
allowing threads different from the main one to call
the
rd_kafka_toppar_set_fetch_state
function, given they hold the lock on therktp
. - In v2.1.0, a bug was fixed which caused polling any queue to reset the
max.poll.interval.ms
. Only certain functions were made to reset the timer, but it is possible for the user to obtain the queue with messages from the broker, skipping these functions. This was fixed by encoding information in a queue itself, that, whether polling, resets the timer.
Checksums
Release asset checksums:
- v2.1.1.zip SHA256
3b8a59f71e22a8070e0ae7a6b7ad7e90d39da8fddc41ce6c5d596ee7f5a4be4b
- v2.1.1.tar.gz SHA256
7be1fc37ab10ebdc037d5c5a9b35b48931edafffae054b488faaff99e60e0108