Anpassungen des Projekts/Setups aus 'simple-producer' übernommen

[demos/kafka/training] / README.sh

diff --git a/README.sh b/README.sh
index 3f46c04..b1ba0be 100755 (executable)
--- a/README.sh
+++ b/README.sh
@@ -1,6 +1,6 @@
 #!/bin/bash
 
-IMAGE=juplo/simple-producer:1.0-SNAPSHOT
+IMAGE=juplo/simple-consumer:1.0-SNAPSHOT
 
 if [ "$1" = "cleanup" ]
 then
@@ -30,6 +30,7 @@ sleep 5
 
 docker-compose exec cli kafkacat -b kafka:9092 -t test -q -c 20 -f'topic=%t\tpartition=%p\toffset=%o\tkey=%k\tvalue=%s\n'
 
-docker-compose stop producer
-docker-compose exec cli kafkacat -b kafka:9092 -t test -q -e -f'topic=%t\tpartition=%p\toffset=%o\tkey=%k\tvalue=%s\n'
-docker-compose logs producer
+docker-compose stop producer consumer-1 consumer-2 consumer-3
+docker-compose logs consumer-1
+docker-compose logs consumer-2
+docker-compose logs consumer-3