X-Git-Url: https://juplo.de/gitweb/?p=demos%2Fkafka%2Foutbox;a=blobdiff_plain;f=README.sh;h=3d756ef32f9a4384dca5fafbc4fa7902868ff099;hp=89aa2697c10e3f49e06baaf0017cd2001d6c488b;hb=b6d734cd09d3e23171eaf6235d19e73bc11ab420;hpb=64251b8eafa2534c359e8e2fc243c17b5a97a61a

diff --git a/README.sh b/README.sh
index 89aa269..3d756ef 100755
--- a/README.sh
+++ b/README.sh
@@ -4,22 +4,36 @@ if [ "$1" = "cleanup" ]
 then
   docker-compose down -v
   mvn clean
-  docker image rm juplo/data-jdbc:polling-outbox-2-SNAPSHOT
+  docker image rm juplo/data-jdbc:polling-outbox-2
+  docker image rm juplo/outbox-delivery:polling-outbox-3-SNAPSHOT
   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/data-jdbc:polling-outbox-2) == "" ||
+  $(docker image ls -q juplo/outbox-delivery:polling-outbox-3-SNAPSHOT) == "" ||
   "$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/data-jdbc:polling-outbox-2
+  docker image ls juplo/outbox-delivery:polling-outbox-3-SNAPSHOT
 fi
 
-docker-compose up -d jdbc
+while ! [[ $(docker-compose exec kafka zookeeper-shell zookeeper:2181 ls /brokers/ids 2> /dev/null) =~ 1001 ]];
+do
+  echo "Waiting for kafka...";
+  sleep 1;
+done
+
+docker-compose exec kafka kafka-topics --zookeeper zookeeper:2181 --create --if-not-exists --replication-factor 1 --partitions 3 --topic outbox
+
+
+docker-compose up -d jdbc outbox kafkacat
 
 while ! [[ $(http :8080/actuator/health 2>/dev/null | jq -r .status) == "UP" ]];
 do
@@ -28,7 +42,7 @@ do
 done
 
 
-docker-compose logs --tail=0 -f jdbc &
+docker-compose logs --tail=0 -f jdbc kafkacat &
 
 for i in `seq 1 7`;
 do
@@ -45,8 +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 stop
+docker-compose logs kafkacat | grep peter
+# "kill" the executions of "docker-compose logs ..."
+docker-compose stop jdbc kafkacat