diff --git a/src/main/java/com/snowflake/kafka/connector/internal/streaming/DefaultStreamingConfigValidator.java b/src/main/java/com/snowflake/kafka/connector/internal/streaming/DefaultStreamingConfigValidator.java index 027a3d775..f9141433b 100644 --- a/src/main/java/com/snowflake/kafka/connector/internal/streaming/DefaultStreamingConfigValidator.java +++ b/src/main/java/com/snowflake/kafka/connector/internal/streaming/DefaultStreamingConfigValidator.java @@ -188,8 +188,7 @@ private static class SingleBufferConfigValidator { private void logDoubleBufferingParametersWarning(Map config) { if (InternalBufferParameters.isSingleBufferEnabled(config)) { - List ignoredParameters = - Arrays.asList(BUFFER_FLUSH_TIME_SEC, BUFFER_SIZE_BYTES, BUFFER_COUNT_RECORDS); + List 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 index 623cfc1ae..27bd8aa49 100644 --- 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