Skip to content

v2.1.1

Compare
Choose a tag to compare
@emasab emasab released this 02 May 22:11
· 77 commits to master since this release
c282ba2

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 polled rkmessage (#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 the rktp.
  • 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