Released the version of the implementation for part 2 of the blog series
[demos/kafka/outbox] / README.sh
index b38ba61..bdf4ff6 100755 (executable)
--- a/README.sh
+++ b/README.sh
@@ -4,24 +4,24 @@ if [ "$1" = "cleanup" ]
 then
   docker-compose down -v
   mvn clean
-  docker image rm juplo/data-jdbc:polling-outbox-2-SNAPSHOT
-  docker image rm juplo/outbox-delivery:polling-outbox-2-SNAPSHOT
+  docker image rm juplo/data-jdbc:polling-outbox-2
+  docker image rm juplo/outbox-delivery:polling-outbox-2
   exit
 fi
 
 docker-compose up -d zookeeper kafka
 
 if [[
-  $(docker image ls -q juplo/data-jdbc:polling-outbox-2-SNAPSHOT) == "" ||
-  $(docker image ls -q juplo/outbox-delivery:polling-outbox-2-SNAPSHOT) == "" ||
+  $(docker image ls -q juplo/data-jdbc:polling-outbox-2) == "" ||
+  $(docker image ls -q juplo/outbox-delivery:polling-outbox-2) == "" ||
   "$1" = "build"
 ]]
 then
   mvn install || exit
 else
   echo "Using image existing images:"
-  docker image ls juplo/data-jdbc:polling-outbox-2-SNAPSHOT
-  docker image ls juplo/outbox-delivery:polling-outbox-2-SNAPSHOT
+  docker image ls juplo/data-jdbc:polling-outbox-2
+  docker image ls juplo/outbox-delivery:polling-outbox-2
 fi
 
 while ! [[ $(docker-compose exec kafka zookeeper-shell zookeeper:2181 ls /brokers/ids 2> /dev/null) =~ 1001 ]];
@@ -59,9 +59,9 @@ do
   echo franz$i | http :8080/users
   echo beate$i | http :8080/users
   http DELETE :8080/users/uwe$i
-  sleep 1
 done;
 
 docker-compose exec postgres psql -Uoutbox -c'SELECT * FROM outbox;' -Ppager=0  outbox
+docker-compose logs kafkacat | grep peter
 # "kill" the executions of "docker-compose logs ..."
 docker-compose stop jdbc kafkacat