feedback

Author: wlawt

.env.example

@@ -7,6 +7,7 @@ TIPS_INGRESS_DUAL_WRITE_MEMPOOL=false
 TIPS_INGRESS_KAFKA_BROKERS=localhost:9092
 TIPS_INGRESS_KAFKA_TOPIC=tips-audit
 TIPS_INGRESS_LOG_LEVEL=info
+TIPS_INGRESS_KAFKA_QUEUE_TOPIC=tips-ingress
 
 # Audit service configuration
 TIPS_AUDIT_KAFKA_BROKERS=localhost:9092

crates/ingress/src/main.rs

@@ -55,7 +55,7 @@ struct Config {
     #[arg(
         long,
         env = "TIPS_INGRESS_KAFKA_QUEUE_TOPIC",
-        default_value = "transaction-queue"
+        default_value = "tips-ingress"
     )]
     queue_topic: String,
 

docker-compose.yml

@@ -55,6 +55,7 @@ services:
     command: |
       sh -c "
         kafka-topics --create --if-not-exists --topic tips-audit --bootstrap-server kafka:29092 --partitions 3 --replication-factor 1
+        kafka-topics --create --if-not-exists --topic tips-ingress --bootstrap-server kafka:29092 --partitions 3 --replication-factor 1
         kafka-topics --list --bootstrap-server kafka:29092
       "