feat: changed to use rdkafka lib

demeter-run · Jul 3, 2024 · 7863068 · 7863068
1 parent 5eb80e0
commit 7863068
Show file tree

Hide file tree

Showing 10 changed files with 231 additions and 246 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Cargo.toml b/Cargo.toml
@@ -12,7 +12,6 @@ async-trait = "0.1.80"
 sqlx = { version = "0.7.4", features = ["runtime-tokio-rustls", "sqlite"] }
 tokio = { version = "1.38.0", features = ["macros", "rt-multi-thread", "time"] }
 tonic = "0.11.0"
-kafka = "0.10.0"
 serde = { version = "1.0.203", features = ["derive"] }
 serde_json = "1.0.117"
 tracing = "0.1.40"
@@ -26,6 +25,7 @@ k8s-openapi = { version = "0.22.0", features = ["latest"] }
 kube = { version = "0.92.0", features = ["client"] }
 protoc-wkt = "1.0.0"
 config = { version = "0.14.0", features = ["toml"] }
+rdkafka = "0.36.2"
 
 [dev-dependencies]
 mockall = "0.12.1"

diff --git a/examples/config.toml b/examples/config.toml
@@ -0,0 +1,3 @@
+addr="0.0.0.0:5000"
+db_path="dev.db"
+brokers="localhost:19092"