feat: make httpv2 connection equal to num threads

goto · Feb 28, 2024 · c8cf787 · c8cf787
1 parent dfdf3e3
commit c8cf787
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/main/java/com/gotocompany/firehose/sink/SinkFactoryUtils.java b/src/main/java/com/gotocompany/firehose/sink/SinkFactoryUtils.java
@@ -15,6 +15,7 @@ protected static Map<String, String> addAdditionalConfigsForSinkConnectors(Map<S
         finalConfig.put("SINK_CONNECTOR_SCHEMA_PROTO_ALLOW_UNKNOWN_FIELDS_ENABLE", env.getOrDefault("INPUT_SCHEMA_PROTO_ALLOW_UNKNOWN_FIELDS_ENABLE", "false"));
         finalConfig.put("SINK_CONNECTOR_SCHEMA_MESSAGE_MODE",
                 env.getOrDefault("KAFKA_RECORD_PARSER_MODE", "").equals("key") ? SinkConnectorSchemaMessageMode.LOG_KEY.name() : SinkConnectorSchemaMessageMode.LOG_MESSAGE.name());
+        finalConfig.put("SINK_HTTPV2_MAX_CONNECTIONS", env.getOrDefault("SINK_POOL_NUM_THREADS", "1"));
         return finalConfig;
     }
 }