Fix test

apache · Dec 17, 2024 · 5f66bb8 · 5f66bb8
1 parent 9d88ab0
commit 5f66bb8
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 12 deletions.
diff --git a/...org/apache/streampipes/extensions/connectors/kafka/shared/kafka/KafkaConfigExtractor.java b/...org/apache/streampipes/extensions/connectors/kafka/shared/kafka/KafkaConfigExtractor.java
@@ -129,16 +129,20 @@ public SecurityProtocol getSecurityProtocol(String selectedSecurityConfiguration
   }
 
   public static Map<String, String> parseAdditionalProperties(String text) {
-    return Arrays.stream(text.split("\\R"))
-        .map(String::trim)
-        .filter(line -> !line.isEmpty() && !line.startsWith("#"))
-        .filter(line -> line.contains("="))
-        .map(line -> line.split("=", 2))
-        .collect(Collectors.toMap(
-            parts -> parts[0].trim(),
-            parts -> parts[1].trim(),
-            (existing, replacement) -> replacement,
-            LinkedHashMap::new
-        ));
+    if (text == null || text.isEmpty()) {
+      return Map.of();
+    } else {
+      return Arrays.stream(text.split("\\R"))
+          .map(String::trim)
+          .filter(line -> !line.isEmpty() && !line.startsWith("#"))
+          .filter(line -> line.contains("="))
+          .map(line -> line.split("=", 2))
+          .collect(Collectors.toMap(
+              parts -> parts[0].trim(),
+              parts -> parts[1].trim(),
+              (existing, replacement) -> replacement,
+              LinkedHashMap::new
+          ));
+    }
   }
 }
diff --git a/...n-tests/src/test/java/org/apache/streampipes/integration/adapters/KafkaAdapterTester.java b/...n-tests/src/test/java/org/apache/streampipes/integration/adapters/KafkaAdapterTester.java
@@ -115,7 +115,7 @@ public IAdapterConfiguration prepareAdapter() throws AdapterException {
     // Set format to Json
     ((StaticPropertyAlternatives) (desc)
          .getConfig()
-         .get(7))
+         .get(8))
          .getAlternatives()
          .get(0)
          .setSelected(true);