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::Streams have had the analogous transformation applied.

    • ๐Ÿ”€ Implement Send and Sync on BorrowedMessage, so that holding a reference to a BorrowedMessage across an await point is possible. (#190)

    • ๐Ÿ”€ Implement Sync on OwnedHeaders, which applies transitively to OwnedMessage, so that holding a reference to an OwnedMessage 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 safe TopicPartitionList struct, and not a raw *mut rdkafka_sys::RDKafkaPartitionList pointer. Thanks, @scrogson! (#198).

    • ๐Ÿ›  Fix CMake build on Windows when debug information is enabled (#194).