add support for kafka topic migration

edgeandnode · Nov 4, 2024 · 7c07562 · 7c07562
1 parent 4388a2a
commit 7c07562
Show file tree

Hide file tree

Showing 5 changed files with 389 additions and 81 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Cargo.toml b/Cargo.toml
@@ -9,6 +9,7 @@ path = "src/bin/main.rs"
 
 [dependencies]
 anyhow = "1.0.89"
+bs58 = "0.5.1"
 chrono = { version = "0.4.38", default-features = false, features = ["alloc"] }
 futures-util = "0.3.31"
 prost = "0.13.3"