Update to iggy 0.5.0 (#19)

iggy-rs · Jul 1, 2024 · 9c423f3 · 9c423f3
1 parent ad4a4cf
commit 9c423f3
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 35 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git 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 <[email protected]>"]
 
@@ -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
@@ -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