From: Kai Moritz <kai@juplo.de>
Date: Tue, 31 Jan 2023 18:31:22 +0000 (+0100)
Subject: Code & Setup für acks-Übung überarbeitet
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=4aff371c1aaf01c07b577fabdf09fd577456adec;p=demos%2Fkafka%2Ftraining

Code & Setup für acks-Übung überarbeitet
---

diff --git a/README.sh b/README.sh
index e1cf1d0..7264308 100755
--- a/README.sh
+++ b/README.sh
@@ -1,6 +1,6 @@
 #!/bin/bash
 
-IMAGE=juplo/supersimple-producer:1.0-SNAPSHOT
+IMAGE=juplo/supersimple-producer-endless:1.0-SNAPSHOT
 
 if [ "$1" = "cleanup" ]
 then
diff --git a/docker/docker-compose.yml b/docker/docker-compose.yml
index 2339e29..cb63b42 100644
--- a/docker/docker-compose.yml
+++ b/docker/docker-compose.yml
@@ -212,28 +212,31 @@ services:
       - kafka-3
 
   acks-all:
-    image: juplo/supersimple-producer:1.0-SNAPSHOT
+    image: juplo/supersimple-producer-endless:1.0-SNAPSHOT
     environment:
       spring.kafka.bootstrap-servers: kafka:9092
       spring.kafka.client-id: acks-all
       spring.kafka.template.default-topic: test
       spring.kafka.producer.acks: all
+    command: --key=klaus
 
   acks-1:
-    image: juplo/supersimple-producer:1.0-SNAPSHOT
+    image: juplo/supersimple-producer-endless:1.0-SNAPSHOT
     environment:
       spring.kafka.bootstrap-servers: kafka:9092
       spring.kafka.client-id: acks-1
       spring.kafka.template.default-topic: test
       spring.kafka.producer.acks: 1
+    command: --key=peter
 
   acks-0:
-    image: juplo/supersimple-producer:1.0-SNAPSHOT
+    image: juplo/supersimple-producer-endless:1.0-SNAPSHOT
     environment:
       spring.kafka.bootstrap-servers: kafka:9092
       spring.kafka.client-id: acks-0
       spring.kafka.template.default-topic: test
       spring.kafka.producer.acks: 0
+    command: --key=ute
 
   consumer:
     image: juplo/toolbox
diff --git a/pom.xml b/pom.xml
index ee60567..2104137 100644
--- a/pom.xml
+++ b/pom.xml
@@ -12,7 +12,7 @@
   </parent>
 
   <groupId>de.juplo.kafka</groupId>
-  <artifactId>supersimple-producer</artifactId>
+  <artifactId>supersimple-producer-endless</artifactId>
   <name>Super Simple Producer</name>
   <description>Most minimal Kafka Producer ever!</description>
   <version>1.0-SNAPSHOT</version>
diff --git a/src/main/java/de/juplo/kafka/Application.java b/src/main/java/de/juplo/kafka/Application.java
index fb3a523..3828a7a 100644
--- a/src/main/java/de/juplo/kafka/Application.java
+++ b/src/main/java/de/juplo/kafka/Application.java
@@ -10,6 +10,8 @@ import org.springframework.kafka.core.KafkaTemplate;
 import org.springframework.kafka.support.SendResult;
 import org.springframework.util.concurrent.ListenableFuture;
 
+import java.util.List;
+
 
 // tag::supersimple[]
 @Slf4j
@@ -22,13 +24,20 @@ public class Application implements ApplicationRunner
   @Override
   public void run(ApplicationArguments args)
   {
+    List<String> keys = args.getOptionValues("key");
+    if (keys == null || keys.size() != 1)
+    {
+      log.error("Exactly one key has to be given with --key");
+      return;
+    }
+    String key = keys.get(0);
     for (int i = 0; true; i++)
     {
       // end::supersimple[]
       // tag::callback[]
       ListenableFuture<SendResult<String, String>> listenableFuture =
       // tag::supersimple[]
-          kafkaTemplate.sendDefault(Long.toString(i%10), Long.toString(i));
+          kafkaTemplate.sendDefault(key, Long.toString(i));
       // end::supersimple[]
 
       listenableFuture.addCallback(