diff --git a/sse.kafka.fanout/test.sh b/sse.kafka.fanout/test.sh index 230854a2..2e55f142 100755 --- 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 \