dekaf: Refactor log forwarding a to make it testable, and write tests…

… for it
estuary · Jan 16, 2025 · c56dcac · c56dcac
1 parent 8b5aabc
commit c56dcac
Show file tree

Hide file tree

Showing 6 changed files with 583 additions and 130 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/crates/dekaf/Cargo.toml b/crates/dekaf/Cargo.toml
@@ -28,6 +28,7 @@ unseal = { path = "../unseal" }
 
 aes-siv = { workspace = true }
 anyhow = { workspace = true }
+async-trait = { workspace = true }
 axum = { workspace = true }
 axum-extra = { workspace = true }
 axum-server = { workspace = true }
@@ -74,11 +75,12 @@ url = { workspace = true }
 webpki = { workspace = true }
 
 [dev-dependencies]
-apache-avro = { workspace = true }
 async-process = { path = "../async-process" }
 flowctl = { path = "../flowctl" }
-insta = { workspace = true }
 locate-bin = { path = "../locate-bin" }
+
+apache-avro = { workspace = true }
+insta = { workspace = true }
 rdkafka = { workspace = true }
 reqwest = { workspace = true }
 schema_registry_converter = { workspace = true }