From 5fab21bca849a7785b295f34f2912bef3dfd6d11 Mon Sep 17 00:00:00 2001
From: Philipp Schirmer <philipp.schirmer@bakdata.com>
Date: Fri, 26 Jan 2024 09:24:01 +0100
Subject: [PATCH] Add --application-id parameter

---
 .../com/bakdata/kafka/KafkaStreamsApplication.java    | 11 ++++++-----
 1 file changed, 6 insertions(+), 5 deletions(-)

diff --git a/streams-bootstrap/src/main/java/com/bakdata/kafka/KafkaStreamsApplication.java b/streams-bootstrap/src/main/java/com/bakdata/kafka/KafkaStreamsApplication.java
index 4e66b77e..0373dda3 100644
--- a/streams-bootstrap/src/main/java/com/bakdata/kafka/KafkaStreamsApplication.java
+++ b/streams-bootstrap/src/main/java/com/bakdata/kafka/KafkaStreamsApplication.java
@@ -241,17 +241,18 @@ protected StreamsUncaughtExceptionHandler getUncaughtExceptionHandler() {
 
     public final String getStreamsApplicationId() {
         final String uniqueAppId = this.getUniqueAppId();
-        if(uniqueAppId == null) {
-            if(this.applicationId == null) {
+        if (uniqueAppId == null) {
+            if (this.applicationId == null) {
                 throw new IllegalArgumentException("Must pass --application-id or implement #getUniqueAppId()");
             }
             return this.applicationId;
         }
-        if(this.applicationId == null) {
+        if (this.applicationId == null) {
             return uniqueAppId;
         }
-        if(!uniqueAppId.equals(this.applicationId)) {
-            throw new IllegalArgumentException("Application ID provided via --application-id does not match #getUniqueAppId()");
+        if (!uniqueAppId.equals(this.applicationId)) {
+            throw new IllegalArgumentException(
+                    "Application ID provided via --application-id does not match #getUniqueAppId()");
         }
         return uniqueAppId;
     }