Review fixes

Author: sfc-gh-lkucharski

src/test/java/com/snowflake/kafka/connector/internal/streaming/ChannelStatusCheckIT.java

@@ -42,7 +42,7 @@ void beforeAll() {
     Map<String, String> workerConfig = new HashMap<>();
     workerConfig.put("plugin.discovery", "hybrid_warn");
     // Set a short offset flush interval for faster preCommit calls
-    workerConfig.put("offset.flush.interval.ms", "5000");
+    workerConfig.put("offset.flush.interval.ms", "1000");
     connectCluster =
         new EmbeddedConnectCluster.Builder()
             .name("channel-status-check-cluster")
@@ -127,9 +127,6 @@ void shouldFailConnectorWhenChannelHasErrorsAndToleranceIsNone() throws JsonProc
       channel.setChannelStatus(statusWithErrors);
     }
 
-    // Produce more messages to trigger preCommit which checks channel status
-    produceMessages(5);
-
     // Then: connector task should fail due to channel errors
     await("Connector task failed")
         .atMost(Duration.ofMinutes(2))