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)>
andstd::iter::FromIterator<(String, String)
forClientConfig
(#367).
Thanks, @djKooks.
๐ฅ Breaking change. Change
Consumer::store_offset
to accept the topic, partition, and offset directly (#89, #368). The old API, which took aBorrowedMessage
, is still accessible asConsumer::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
].
- The addition of
Thanks, @SreeniIO.
- ๐ Support reading and writing commit metadata via
TopicPartitionListElem::metadata
andTopicPartitionListElem::set_metadata
, respectively (#391).
Thanks, @phaazon.
- ๐ Allow offset 0 in