X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=README.sh;h=a6a2b36e126717cf013a065b7d725057a9808a00;hb=ca44f2f7e67fb263660adf43f816e5ec98a5e567;hp=6a4ef4cc19eb18ff8b64e68fde54525c238190c8;hpb=b876bd8648a4f919cea5791e5e208a88d9e0cacd;p=demos%2Fkafka%2Foutbox

diff --git a/README.sh b/README.sh
index 6a4ef4c..a6a2b36 100755
--- a/README.sh
+++ b/README.sh
@@ -26,16 +26,16 @@ trap 'kill $(jobs -p)' EXIT
 
 docker-compose up -d zookeeper kafka
 
-while ! [[ $(zookeeper-shell zookeeper:2181 ls /brokers/ids 2> /dev/null) =~ 1001 ]];
+while ! [[ $(docker-compose exec kafka zookeeper-shell zookeeper:2181 ls /brokers/ids 2> /dev/null) =~ 1001 ]];
 do
   echo "Waiting for kafka...";
   sleep 1;
 done
 
-kafka-topics --create --zookeeper zookeeper:2181 --replication-factor 1 --partitions 3 --topic outbox
+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
+docker-compose up -d jdbc outbox kafkacat
 
 while ! [[ $(http :8080/actuator/health 2>/dev/null | jq -r .status) == "UP" ]];
 do
@@ -44,11 +44,19 @@ do
 done
 
 
-kafkacat -C -b localhost:9092 -t outbox &
+docker-compose logs -f kafkacat &
 
-echo peter | http :8080/users
-echo franz | http :8080/users
-echo beate | http :8080/users
-http :8080/users
-http DELETE :8080/users/franz
-http :8080/users
+for i in `seq 1 20`;
+do
+  echo peter$i | http :8080/users
+  echo uwe$i | http :8080/users
+  echo simone$i | http :8080/users
+  http DELETE :8080/users/franz$i
+  http DELETE :8080/users/simone$i
+  echo franz$i | http :8080/users
+  echo beate$i | http :8080/users
+  http DELETE :8080/users/uwe$i
+  sleep 1
+done;
+
+sleep 2