From: Kai Moritz Date: Sun, 16 May 2021 21:31:38 +0000 (+0200) Subject: Released the version of the implementation for part 2 of the blog series X-Git-Tag: part-2 X-Git-Url: https://juplo.de/gitweb/?p=demos%2Fkafka%2Foutbox;a=commitdiff_plain;h=ede36c391f3bd58d01e67bdd0505d247302eed22 Released the version of the implementation for part 2 of the blog series --- diff --git a/README.md b/README.md index 2c61a4e..d1ebf87 100644 --- a/README.md +++ b/README.md @@ -1,7 +1,7 @@ # Implementation of the Outbox-Pattern for Apache Kafka This Repository holds the source code for -[a blog-series that explains a technically complete implementation of the outbox-pattern for Apache Kafka](https://juplo.de/implementing-the-outbox-pattern-with-kafka-part-1-the-outbox-table/). +[a blog-series that explains a technically complete implementation of the outbox-pattern for Apache Kafka](https://juplo.de/implementing-the-outbox-pattern-with-kafka-part-2-sending-messages-from-the-outbox/). Execute [README.sh](README.sh) in a shell to demonstrate the example: diff --git a/README.sh b/README.sh index b38ba61..bdf4ff6 100755 --- 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 diff --git a/delivery/pom.xml b/delivery/pom.xml index faef6a9..8af0eee 100644 --- a/delivery/pom.xml +++ b/delivery/pom.xml @@ -15,7 +15,7 @@ de.juplo.kafka.outbox outbox-delivery - polling-outbox-2-SNAPSHOT + polling-outbox-2 Outbox-Delivery (Polling) Simple example-implementation of the Outbox-Pattern (polling variant) diff --git a/docker-compose.yml b/docker-compose.yml index 93f6b0d..4784958 100644 --- a/docker-compose.yml +++ b/docker-compose.yml @@ -30,7 +30,7 @@ services: - kafka jdbc: - image: juplo/data-jdbc:polling-outbox-2-SNAPSHOT + image: juplo/data-jdbc:polling-outbox-2 ports: - 8080:8080 environment: @@ -39,7 +39,7 @@ services: - postgres outbox: - image: juplo/outbox-delivery:polling-outbox-2-SNAPSHOT + image: juplo/outbox-delivery:polling-outbox-2 environment: spring.profiles.active: prod logging.level.de.juplo.kafka.outbox: DEBUG diff --git a/jdbc b/jdbc index bd0d272..7c43d44 160000 --- a/jdbc +++ b/jdbc @@ -1 +1 @@ -Subproject commit bd0d27231000709358794cf034ab6c2b0b3db8ab +Subproject commit 7c43d44ee5deac1d1dc6680a30c5131ac5a023ba diff --git a/pom.xml b/pom.xml index 7f98c54..d3e4618 100644 --- a/pom.xml +++ b/pom.xml @@ -8,7 +8,7 @@ de.juplo.kafka.outbox polling-outbox-parent - polling-outbox-2-SNAPSHOT + polling-outbox-2 pom polling-outbox-parent Simple example-implementation of the Polling-Outbox-Pattern diff --git a/postage/pom.xml b/postage/pom.xml index 9892acd..92dde3d 100644 --- a/postage/pom.xml +++ b/postage/pom.xml @@ -15,7 +15,7 @@ de.juplo.kafka.outbox outbox-postage - polling-outbox-2-SNAPSHOT + polling-outbox-2 outbox-postage Simple example-implementation of the Polling-Outbox-Pattern