refactor kafka producer

fixes #11, #13, #22
nxthdr · Feb 15, 2025 · 873e6d6 · 873e6d6
1 parent 4c51c00
commit 873e6d6
Show file tree

Hide file tree

Showing 11 changed files with 381 additions and 418 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Cargo.toml b/Cargo.toml
@@ -6,6 +6,7 @@ edition = "2021"
 # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
 
 [dependencies]
+anyhow = "1.0.95"
 axum = "0.8.1"
 bgpkit-parser = { version = "0.10.11", features = ["serde"] }
 bytes = "1.9.0"
@@ -14,11 +15,11 @@ clap = { version = "4.5.23", features = ["derive"] }
 clap-verbosity-flag = "3.0.2"
 config = "0.15.4"
 env_logger = "0.11.6"
-kafka = "0.10.0"
 log = "0.4.22"
 metrics = "0.24.1"
 metrics-exporter-prometheus = "0.16.0"
 rand = "0.9.0"
+rdkafka = "0.37.0"
 serde = { version = "1.0.217", features = ["derive"] }
 serde_json = "1.0.134"
 tokio = { version = "1.42.0", features = ["full"] }