diff --git a/  b/ 
new file mode 100755
index 0000000..5f1be3f
Binary files /dev/null and b/  differ
diff --git a/infra/docker-compose.dev.yml b/infra/docker-compose.dev.yml
index 69786b1..029b700 100644
--- a/infra/docker-compose.dev.yml
+++ b/infra/docker-compose.dev.yml
@@ -1,3 +1,4 @@
+name: aigis-dev
 version: '3.8'
 services:
   kafka:
diff --git a/infra/docker-compose.kafka-cluster.yml b/infra/docker-compose.kafka-cluster.yml
index 89464c2..e9a095a 100644
--- a/infra/docker-compose.kafka-cluster.yml
+++ b/infra/docker-compose.kafka-cluster.yml
@@ -1,3 +1,4 @@
+name: aigis-kafka-cluster
 version: '3.8'
 services:
   kafka-1:
diff --git a/infra/docker-compose.yml b/infra/docker-compose.yml
index 2edbae0..4fbc97c 100644
--- a/infra/docker-compose.yml
+++ b/infra/docker-compose.yml
@@ -1,3 +1,4 @@
+name: aigis-infra
 version: "3.9"
 
 services:
diff --git a/kafka-pipeline/src/consumer.rs b/kafka-pipeline/src/consumer.rs
index 10d627e..24b7aa6 100644
--- a/kafka-pipeline/src/consumer.rs
+++ b/kafka-pipeline/src/consumer.rs
@@ -43,7 +43,7 @@ impl ConsumerWorker {
             .set("enable.auto.commit", "true")
             .set("auto.commit.interval.ms", "1000")
             .set("fetch.min.bytes", "1")
-            .set("fetch.max.wait.ms", "100")
+            .set("fetch.wait.max.ms", "100")
             .set("max.poll.interval.ms", "300000")
             .set("session.timeout.ms", "45000")
             .create()
diff --git a/kafka-pipeline/src/main.rs b/kafka-pipeline/src/main.rs
index 620f411..d919306 100644
--- a/kafka-pipeline/src/main.rs
+++ b/kafka-pipeline/src/main.rs
@@ -7,7 +7,6 @@ pub mod event_router;
 #[tokio::main]
 async fn main() -> anyhow::Result<()> {
     tracing_subscriber::fmt()
-        .with_env_filter("info")
         .json()
         .init();