fix: fix checkstyle (#37)

* fix: fix checkstyle * fix: fix checkstyle * fix: fix checkstyle * fix: fix checkstyle
goto · Apr 24, 2024 · a3fae5a · a3fae5a
1 parent e021eeb
commit a3fae5a
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/src/main/java/com/gotocompany/firehose/sink/httpv2/HttpV2SinkUtils.java b/src/main/java/com/gotocompany/firehose/sink/httpv2/HttpV2SinkUtils.java
@@ -8,12 +8,18 @@ public class HttpV2SinkUtils {
 
     public static void addAdditionalConfigsForHttpV2Sink(Map<String, String> env) {
 
-        switch (KafkaConsumerMode.valueOf(env.getOrDefault("SOURCE_KAFKA_CONSUMER_MODE", "SYNC"))) {
+        System.out.println(env.getOrDefault("SOURCE_KAFKA_CONSUMER_MODE", "SYNC").toUpperCase());
+        switch (KafkaConsumerMode.valueOf(env.getOrDefault("SOURCE_KAFKA_CONSUMER_MODE", "SYNC").toUpperCase())) {
             case SYNC:
                 env.put("SINK_HTTPV2_MAX_CONNECTIONS", "1");
                 break;
+
             case ASYNC:
                 env.put("SINK_HTTPV2_MAX_CONNECTIONS", env.getOrDefault("SINK_POOL_NUM_THREADS", "1"));
+                break;
+            default:
+                throw new IllegalArgumentException("Consumer mode should be async or sync");
+
         }
     }
 }