Typ der Partition ist `Integer`: Demonstration des Fallbacks bei `null`

* Die Idee, das Verhalten bei `null` in mit einer gemeinsamen Vorlage in
  einer Übung aufzuzeigen, ist für die Übungen nicht gut geeignet.
* _Grund:_ Während der Umsetzung werden immer einige TN die Anwendung aus
  der IDE heraus ausführen.
* Dabei wäre dann durch die gemeinsame Vorlage, die in der `application.yml`
  keinen Wert für die Partition vorgeben kann, `null` als Partition
  vorgegeben, so dass die Umsetzung (scheinbar) nicht funktioniert!
* In der eingebauten `application.yml` kann kein Wert vorgegeben werden, da
  dieser sonst später nicht überschrieben werden kann!
* Experimente haben gezeigt, dass sowohl eine leere Vorgabe, als auch die
  Vorgabe `null` (ohne Anführungszeichen), in der `docker-compose.yml` den
  Wert nicht zurücksetzen.

diff --git a/README.sh b/README.sh
index 668e756..01372f7 100755 (executable)
--- a/README.sh
+++ b/README.sh
@@ -39,4 +39,4 @@ echo
 echo "Von consumer-2 empfangen:"
 docker compose -f docker/docker-compose.yml logs consumer-2 | grep '\ test\/.'
 
-docker compose -f docker/docker-compose.yml stop consumer-1 consumer-2
+docker compose -f docker/docker-compose.yml rm -svf consumer-1 consumer-2

diff --git a/src/main/java/de/juplo/kafka/ApplicationProperties.java b/src/main/java/de/juplo/kafka/ApplicationProperties.java
index 8eebd09..8a263e8 100644 (file)
--- a/src/main/java/de/juplo/kafka/ApplicationProperties.java
+++ b/src/main/java/de/juplo/kafka/ApplicationProperties.java
@@ -39,7 +39,6 @@ public class ApplicationProperties
     @NotNull
     @NotEmpty
     private String topic;
-    @NotNull
     private Integer partition;
     @NotNull
     @NotEmpty

diff --git a/src/main/java/de/juplo/kafka/ExampleProducer.java b/src/main/java/de/juplo/kafka/ExampleProducer.java
index 2d043c2..23b4f90 100644 (file)
--- a/src/main/java/de/juplo/kafka/ExampleProducer.java
+++ b/src/main/java/de/juplo/kafka/ExampleProducer.java
@@ -10,7 +10,7 @@ public class ExampleProducer implements Runnable
 {
   private final String id;
   private final String topic;
-  private final int partition;
+  private final Integer partition;
   private final int throttleMs;
   private final Producer<String, String> producer;
   private final Thread workerThread;
@@ -22,7 +22,7 @@ public class ExampleProducer implements Runnable
   public ExampleProducer(
     String id,
     String topic,
-    int partition,
+    Integer partition,
     int throttleMs,
     Producer<String, String> producer)
   {

diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml
index 79c5c98..b06f974 100644 (file)
--- a/src/main/resources/application.yml
+++ b/src/main/resources/application.yml
@@ -3,7 +3,6 @@ juplo:
   client-id: DEV
   producer:
     topic: test
-    partition: 0
     acks: -1
     batch-size: 16384
     linger-ms: 0