add consumer subscriptions for looped messages

redbadger · Dec 22, 2023 · a6d4baa · a6d4baa
1 parent ac8f126
commit a6d4baa
Show file tree

Hide file tree

Showing 5 changed files with 310 additions and 14 deletions.
diff --git a/rust-containers-k8s/notification-service/Cargo.lock b/rust-containers-k8s/notification-service/Cargo.lock
diff --git a/rust-containers-k8s/notification-service/Cargo.toml b/rust-containers-k8s/notification-service/Cargo.toml
@@ -7,7 +7,10 @@ edition = "2021"
 
 [dependencies]
 anyhow = "1.0.76"
-rdkafka = { version = "0.36.0" }
+dotenv = "0.15.0"
+envy = "0.4.2"
+kafka = "0.10.0"
+rdkafka = "0.35.0"
 serde = { version = "1.0.193", features = ["derive"] }
 serde_json = "1.0.108"
 tokio =  { version = "1.35.1", features = ["full"] }