Fix Kafka stress test: remove invalid param

Author: aIbrahiim

it/kafka/src/test/java/org/apache/beam/it/kafka/KafkaIOST.java

@@ -299,7 +299,6 @@ private PipelineLauncher.LaunchInfo generateDataAndWrite() throws IOException {
             .addParameter("maxNumWorkers", String.valueOf(configuration.maxNumWorkers))
             .addParameter("experiments", configuration.useDataflowRunnerV2 ? "use_runner_v2" : "")
             .addParameter("enableStreamingEngine", "true") // Enable streaming engine
-            .addParameter("streamingMode", "true") // Enable streaming mode
             .addParameter("usePublicIps", "false") // Use private IPs for better performance
             .addParameter("subnetwork", "regions/us-central1/subnetworks/default") // Use default subnet
             .build();
@@ -333,7 +332,6 @@ private PipelineLauncher.LaunchInfo readData() throws IOException {
             .addParameter("runner", configuration.runner)
             .addParameter("experiments", configuration.useDataflowRunnerV2 ? "use_runner_v2" : "")
             .addParameter("enableStreamingEngine", "true") // Enable streaming engine
-            .addParameter("streamingMode", "true") // Enable streaming mode
             .addParameter("usePublicIps", "false") // Use private IPs for better performance
             .addParameter("subnetwork", "regions/us-central1/subnetworks/default") // Use default subnet
             .build();