Add repoll timer to reducers

john-z-yang · Jan 19, 2025 · 58aabfb · 58aabfb
1 parent 122b511
commit 58aabfb
Show file tree

Hide file tree

Showing 6 changed files with 156 additions and 142 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Cargo.toml b/Cargo.toml
@@ -6,7 +6,7 @@ edition = "2021"
 # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
 
 [dependencies]
-rdkafka = { version = "0.36.2", features = ["cmake-build"] }
+rdkafka = { version = "0.37.0", features = ["cmake-build"] }
 tokio = { version = "1.41.0", features = ["full"] }
 tokio-util = "0.7.12"
 tokio-stream = { version = "0.1.16", features = ["full"] }
@@ -19,3 +19,4 @@ tracing-subscriber = "0.3.18"
 reqwest = { version = "0.12.9", features = ["json", "stream"] }
 serde = "1.0.214"
 serde_json = "1.0.132"
+elegant-departure = "0.3.1"