chore: define compose project names, fix kafka consumer config key, and allow dynamic tracing filter levels

infra/docker-compose.dev.yml

@@ -1,3 +1,4 @@
+name: aigis-dev
 version: '3.8'
 services:
   kafka:

infra/docker-compose.kafka-cluster.yml

@@ -1,3 +1,4 @@
+name: aigis-kafka-cluster
 version: '3.8'
 services:
   kafka-1:

infra/docker-compose.yml

@@ -1,3 +1,4 @@
+name: aigis-infra
 version: "3.9"
 
 services:

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()

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();