Add --application-id parameter

bakdata · Jan 26, 2024 · 5fab21b · 5fab21b
1 parent eafd69e
commit 5fab21b
Showing 1 changed file with 6 additions and 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
@@ -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;
     }