if [ "$1" = "cleanup" ]
then
docker-compose down -v
+ mvn clean
+ docker image rm juplo/seek:1.0-SNAPSHOT
exit
fi
docker-compose up -d zookeeper kafka
+if [[
+ $(docker image ls -q juplo/seek:1.0-SNAPSHOT) == "" ||
+ "$1" = "build"
+]]
+then
+ mvn install || exit
+else
+ echo "Using image existing images:"
+ docker image ls juplo/seek:1.0-SNAPSHOT
+fi
+
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 1 --topic foo
-
-docker-compose up -d producer consumer
+docker-compose exec kafka kafka-topics --zookeeper zookeeper:2181 --create --if-not-exists --replication-factor 1 --partitions 7 --topic test
+docker-compose up -d producer
+docker-compose up -d perter franz beate ute klaus paul sigi
sleep 3
-docker-compose exec kafka kafka-consumer-groups --bootstrap-server :9092 --group bar --reset-offsets --to-earliest
+docker-compose exec kafka kafka-consumer-groups --bootstrap-server :9092 --group seek --reset-offsets --to-earliest
sleep 3
-docker-compose exec kafka kafka-consumer-groups --bootstrap-server :9092 --group bar --reset-offsets --to-earliest
+docker-compose exec kafka kafka-consumer-groups --bootstrap-server :9092 --group seek --reset-offsets --to-earliest
sleep 3
-docker-compose exec kafka kafka-consumer-groups --bootstrap-server :9092 --group bar --reset-offsets --to-earliest
+docker-compose exec kafka kafka-consumer-groups --bootstrap-server :9092 --group seek --reset-offsets --to-earliest
-docker-compose stop producer consumer
+docker-compose stop producer franz beate ute klaus paul sigi
docker-compose logs consumer