From a83d1244e825c966485b222f5d9439d467f251e6 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Wed, 12 Mar 2025 06:45:10 +0100
Subject: [PATCH] =?utf8?q?R=C3=9CCKBAU=20f=C3=BCr=20Rebase=20der=20Folge-B?=
 =?utf8?q?ranches?=
MIME-Version: 1.0
Content-Type: text/plain; charset=utf8
Content-Transfer-Encoding: 8bit

---
 .../java/de/juplo/kafka/ExampleConsumer.java  | 38 ++++++++++---------
 1 file changed, 21 insertions(+), 17 deletions(-)

diff --git a/src/main/java/de/juplo/kafka/ExampleConsumer.java b/src/main/java/de/juplo/kafka/ExampleConsumer.java
index 865e5cbe..891af891 100644
--- a/src/main/java/de/juplo/kafka/ExampleConsumer.java
+++ b/src/main/java/de/juplo/kafka/ExampleConsumer.java
@@ -98,26 +98,25 @@ public class ExampleConsumer
 
   public static void main(String[] args) throws Exception
   {
-    if (args.length != 4)
+    String broker = ":9092";
+    String topic = "test";
+    String groupId = "my-group";
+    String clientId = "DEV";
+
+    switch (args.length)
     {
-      log.error("Four arguments required!");
-      log.error("args[0]: Broker-Address");
-      log.error("args[1]: Topic");
-      log.error("args[2]: Group-ID");
-      log.error("args[3]: Unique Client-ID");
-      System.exit(1);
-      return;
+      case 4:
+        clientId = args[3];
+      case 3:
+        groupId = args[2];
+      case 2:
+        topic = args[1];
+      case 1:
+        broker = args[0];
     }
 
 
-    log.info(
-      "Running ExampleConsumer: broker={}, topic={}, group-id={}, client-id={}",
-      args[0],
-      args[1],
-      args[2],
-      args[3]);
-
-    ExampleConsumer instance = new ExampleConsumer(args[0], args[1], args[2], args[3]);
+    ExampleConsumer instance = new ExampleConsumer(broker, topic, groupId, clientId);
 
     Runtime.getRuntime().addShutdownHook(new Thread(() ->
     {
@@ -135,7 +134,12 @@ public class ExampleConsumer
       log.info("Shutdown completed.");
     }));
 
+    log.info(
+      "Running ExampleConsumer: broker={}, topic={}, group-id={}, client-id={}",
+      broker,
+      topic,
+      groupId,
+      clientId);
     instance.run();
   }
 }
-  
-- 
2.20.1