rust-rdkafka v0.27.0 Release Notes

Release Date: 2021-10-17 // over 2 years ago
    • ๐Ÿ‘ Allow offset 0 in Offset::to_raw.

    Thanks, [@roignpar].

    • ๐Ÿ›  Fix a segfault when calling Consumer::position on a consumer that was improperly configured (#360).

    • ๐Ÿ›ฐ Provide a mutable accessor (Message::payload_mut) for a message's payload (#95).

    • Implement std::iter::Extend<(String, String)> and std::iter::FromIterator<(String, String) for ClientConfig (#367).

    Thanks, @djKooks.

    • ๐Ÿ’ฅ Breaking change. Change Consumer::store_offset to accept the topic, partition, and offset directly (#89, #368). The old API, which took a BorrowedMessage, is still accessible as Consumer::store_offset_from_message.

    • ๐Ÿ‘Œ Support incremental cooperative rebalancing (#364). There are two changes of note:

      • The addition of Consumer::rebalance_protocol to determine the rebalance protocol in use.
      • The modification of the default rebalance callback (ConsumerContext::rebalance) to perform incremental assignments and unassignments when the rebalance protocol in use is [RebalanceProtocol::Cooperative].

    Thanks, @SreeniIO.

    • ๐Ÿ‘Œ Support reading and writing commit metadata via TopicPartitionListElem::metadata and TopicPartitionListElem::set_metadata, respectively (#391).

    Thanks, @phaazon.