SNOW-1686497 Remove single buffer warning for "buffer.size.bytes"

snowflakedb · Oct 7, 2024 · a9d8580 · a9d8580
1 parent 3bf31ff
commit a9d8580
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/...ava/com/snowflake/kafka/connector/internal/streaming/DefaultStreamingConfigValidator.java b/...ava/com/snowflake/kafka/connector/internal/streaming/DefaultStreamingConfigValidator.java
@@ -188,8 +188,7 @@ private static class SingleBufferConfigValidator {
 
     private void logDoubleBufferingParametersWarning(Map<String, String> config) {
       if (InternalBufferParameters.isSingleBufferEnabled(config)) {
-        List<String> ignoredParameters =
-            Arrays.asList(BUFFER_FLUSH_TIME_SEC, BUFFER_SIZE_BYTES, BUFFER_COUNT_RECORDS);
+        List<String> ignoredParameters = Arrays.asList(BUFFER_FLUSH_TIME_SEC, BUFFER_COUNT_RECORDS);
         ignoredParameters.stream()
             .filter(config::containsKey)
             .forEach(

diff --git a/src/test/java/com/snowflake/kafka/connector/ConnectorConfigValidatorLogsTest.java b/src/test/java/com/snowflake/kafka/connector/ConnectorConfigValidatorLogsTest.java
@@ -45,7 +45,7 @@ public void testRSAPasswordOutput() throws IOException, OperatorCreationExceptio
   }
 
   @ParameterizedTest
-  @ValueSource(strings = {BUFFER_FLUSH_TIME_SEC, BUFFER_SIZE_BYTES, BUFFER_COUNT_RECORDS})
+  @ValueSource(strings = {BUFFER_FLUSH_TIME_SEC, BUFFER_COUNT_RECORDS})
   public void shouldLogWarningIfBufferingPropertiesDefinedForSingleBuffer(String parameter)
       throws IOException {
     // given