diff --git a/Cargo.lock b/Cargo.lock index 6f0e038..6b5ab60 100644 --- a/Cargo.lock +++ b/Cargo.lock @@ -379,12 +379,6 @@ dependencies = [ "syn 1.0.109", ] -[[package]] -name = "byteorder" -version = "1.5.0" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "1fd0f2584146f6f2ef48085050886acf353beff7305ebd1ae69500e27c67f64b" - [[package]] name = "bytes" version = "1.6.0" @@ -1094,9 +1088,9 @@ dependencies = [ [[package]] name = "iggy" -version = "0.4.3" +version = "0.5.0" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "3a680b668a5bbefadc3c198f6fddc55b2de1d8aac9a11705f369f6cd8333fe21" +checksum = "d8e9f5753cf77cc7f532d244873ae71d9c5a8007b03a7250b650f85a0ac06321" dependencies = [ "aes-gcm", "anyhow", @@ -1119,7 +1113,6 @@ dependencies = [ "reqwest", "reqwest-middleware", "reqwest-retry", - "rmp-serde", "rustls", "serde", "serde_derive", @@ -1136,7 +1129,7 @@ dependencies = [ [[package]] name = "iggy-py" -version = "0.2.2" +version = "0.2.3" dependencies = [ "bytes", "iggy", @@ -2089,28 +2082,6 @@ dependencies = [ "syn 1.0.109", ] -[[package]] -name = "rmp" -version = "0.8.14" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "228ed7c16fa39782c3b3468e974aec2795e9089153cd08ee2e9aefb3613334c4" -dependencies = [ - "byteorder", - "num-traits", - "paste", -] - -[[package]] -name = "rmp-serde" -version = "1.3.0" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "52e599a477cf9840e92f2cde9a7189e67b42c57532749bf90aea6ec10facd4db" -dependencies = [ - "byteorder", - "rmp", - "serde", -] - [[package]] name = "rust_decimal" version = "1.35.0" diff --git a/Cargo.toml b/Cargo.toml index b08a073..db379b6 100644 --- a/Cargo.toml +++ b/Cargo.toml @@ -1,6 +1,6 @@ [package] name = "iggy-py" -version = "0.2.2" +version = "0.2.3" edition = "2021" authors = ["Dario Lencina Talarico "] @@ -11,7 +11,7 @@ crate-type = ["cdylib"] [dependencies] pyo3 = "0.22.0" -iggy = "0.4.3" +iggy = "0.5.0" tokio = { version = "1", features = ["full"] } bytes = "1.5" openssl = { version = "0.10.*", features = ["vendored"] } diff --git a/src/client.rs b/src/client.rs index 2c73544..aa33dd7 100644 --- a/src/client.rs +++ b/src/client.rs @@ -9,6 +9,7 @@ use iggy::identifier::Identifier; use iggy::messages::poll_messages::PollingStrategy; use iggy::messages::send_messages::{Message as RustMessage, Partitioning}; use iggy::utils::expiry::IggyExpiry; +use iggy::utils::topic_size::MaxTopicSize; use pyo3::prelude::*; use pyo3::types::PyList; use tokio::runtime::{Builder, Runtime}; @@ -125,7 +126,7 @@ impl IggyClient { replication_factor, topic_id, IggyExpiry::NeverExpire, - None, + MaxTopicSize::ServerDefault, ); let _create_topic = self .runtime