rust-rdkafka v0.23.0 Release Notes
Release Date: 2019-12-31 // about 4 years ago-
- โฌ๏ธ Upgrade to the async/await ecosystem, including
std::future::Future
, v0.3 of the futures crate, and v0.2 of Tokio. The minimum supported Rust version is now Rust 1.39. Special thanks to @sd2k and @dbcfd. (#187)
The main difference is that functions that previously returned
futures01::Future<Item = T, Error = E>
now return:
std::future::Future<Output = Result<T, E>>
In the special case when the error was
()
, the new signature is further simplified to:std::future::Future<Output = T>
Functions that return
future::Stream
s have had the analogous transformation applied.๐ Implement
Send
andSync
onBorrowedMessage
, so that holding a reference to aBorrowedMessage
across an await point is possible. (#190)๐ Implement
Sync
onOwnedHeaders
, which applies transitively toOwnedMessage
, so that holding a reference to anOwnedMessage
across an await point is possible. (#203)โฌ๏ธ Bump librdkafka to v1.3.0. (#202)
๐ Change the signature of
ConsumerContext::commit_callback
so that the offsets are passed via a safeTopicPartitionList
struct, and not a raw*mut rdkafka_sys::RDKafkaPartitionList
pointer. Thanks, @scrogson! (#198).๐ Fix CMake build on Windows when debug information is enabled (#194).
- โฌ๏ธ Upgrade to the async/await ecosystem, including