X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=README.sh;h=ede86234f76519e908e78daa64dd082e1f1ed8cd;hb=59f2c7fe0c84391f55f04aebd171787c4405d635;hp=74eb764f62e287aaf1ce90ec1206296c4f634142;hpb=309991dd1720e78bead9ea6788a1ab491fe0b625;p=demos%2Fkafka%2Ftraining diff --git a/README.sh b/README.sh index 74eb764..ede8623 100755 --- a/README.sh +++ b/README.sh @@ -21,6 +21,8 @@ sleep 5 docker-compose start consumer-3 docker-compose stop consumer-1 +sleep 1 +docker-compose start consumer-2 sleep 5 docker-compose start consumer-1 @@ -29,7 +31,15 @@ sleep 5 docker-compose stop producer consumer-1 consumer-2 consumer-3 docker-compose logs consumer-1 -echo "Received messages for test/0" +echo "Messages received by consumer-1 for test/0" docker-compose logs consumer-1 | grep test/0 -echo "Received messages for test/1" +echo "Messages received by consumer-2 for test/0" +docker-compose logs consumer-2 | grep test/0 +echo "Messages received by consumer-3 for test/0" +docker-compose logs consumer-3 | grep test/0 +echo "Messages received by consumer-1 for test/1" docker-compose logs consumer-1 | grep test/1 +echo "Messages received by consumer-2 for test/1" +docker-compose logs consumer-2 | grep test/1 +echo "Messages received by consumer-3 for test/1" +docker-compose logs consumer-3 | grep test/1