fix: fix checkstyle

goto · Apr 24, 2024 · e67bbbe · e67bbbe
1 parent e7e3115
commit e67bbbe
Showing 1 changed file with 1 addition 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,7 +8,7 @@ public class HttpV2SinkUtils {
 
     public static void addAdditionalConfigsForHttpV2Sink(Map<String, String> env) {
 
-        switch (KafkaConsumerMode.valueOf(env.getOrDefault("SOURCE_KAFKA_CONSUMER_MODE", "SYNC"))) {
+        switch (KafkaConsumerMode.valueOf(env.getOrDefault("SOURCE_KAFKA_CONSUMER_MODE", "SYNC").toUpperCase())) {
             case SYNC:
                 env.put("SINK_HTTPV2_MAX_CONNECTIONS", "1");
                 break;