fix test

aklivity · Nov 8, 2024 · 99a2f8e · 99a2f8e
1 parent 745ebc1
commit 99a2f8e
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/sse.kafka.fanout/test.sh b/sse.kafka.fanout/test.sh
@@ -6,8 +6,8 @@ EXIT=0
 # GIVEN
 PORT="7114"
 KAFKA_BOOTSTRAP_SERVER="kafka:29092"
-INPUT='{"id": 1,"name":"Hello World!"}'
-EXPECTED='data:{ "id": 1, "name": "Hello World!"}'
+INPUT='{"id":1,"name":"Hello World!"}'
+EXPECTED='data:{"id":1,"name":"Hello World!"}'
 echo \# Testing sse.kafka.fanout/
 echo PORT="$PORT"
 echo KAFKA_BOOTSTRAP_SERVER="$KAFKA_BOOTSTRAP_SERVER"
@@ -21,7 +21,7 @@ timeout 3s curl -N --http2 -H "Accept:text/event-stream" "http://localhost:$PORT
 
 # push response to kafka with kafkacat
 echo "$INPUT" |
-  docker compose -p zilla-http-kafka-sync exec -T kafkacat \
+  docker compose -p zilla-sse-kafka-fanout exec -T kafkacat \
     kafkacat -P \
     -b $KAFKA_BOOTSTRAP_SERVER \
     -t events \