Released the version of the implementation for part 2 of the blog series part-2
authorKai Moritz <kai@juplo.de>
Sun, 16 May 2021 21:31:38 +0000 (23:31 +0200)
committerKai Moritz <kai@juplo.de>
Sun, 16 May 2021 21:45:43 +0000 (23:45 +0200)
README.md
README.sh
delivery/pom.xml
docker-compose.yml
jdbc
pom.xml
postage/pom.xml

index 2c61a4e..d1ebf87 100644 (file)
--- 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:
 
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
index faef6a9..8af0eee 100644 (file)
@@ -15,7 +15,7 @@
 
   <groupId>de.juplo.kafka.outbox</groupId>
   <artifactId>outbox-delivery</artifactId>
-  <version>polling-outbox-2-SNAPSHOT</version>
+  <version>polling-outbox-2</version>
   <name>Outbox-Delivery (Polling)</name>
   <description>Simple example-implementation of the Outbox-Pattern (polling variant)</description>
 
index 93f6b0d..4784958 100644 (file)
@@ -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 (submodule)
--- a/jdbc
+++ b/jdbc
@@ -1 +1 @@
-Subproject commit bd0d27231000709358794cf034ab6c2b0b3db8ab
+Subproject commit 7c43d44ee5deac1d1dc6680a30c5131ac5a023ba
diff --git a/pom.xml b/pom.xml
index 7f98c54..d3e4618 100644 (file)
--- a/pom.xml
+++ b/pom.xml
@@ -8,7 +8,7 @@
 
   <groupId>de.juplo.kafka.outbox</groupId>
   <artifactId>polling-outbox-parent</artifactId>
-  <version>polling-outbox-2-SNAPSHOT</version>
+  <version>polling-outbox-2</version>
   <packaging>pom</packaging>
   <name>polling-outbox-parent</name>
   <description>Simple example-implementation of the Polling-Outbox-Pattern</description>
index 9892acd..92dde3d 100644 (file)
@@ -15,7 +15,7 @@
 
   <groupId>de.juplo.kafka.outbox</groupId>
   <artifactId>outbox-postage</artifactId>
-  <version>polling-outbox-2-SNAPSHOT</version>
+  <version>polling-outbox-2</version>
   <name>outbox-postage</name>
   <description>Simple example-implementation of the Polling-Outbox-Pattern</description>