Increase number of network threads (#2081)

* Increase number of network threads to avoid disconnections from broker 0 * Same fix for AlterConfig integration test
confluentinc · Jul 12, 2023 · ee5fc62 · ee5fc62
1 parent 4ff4e29
commit ee5fc62
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 9 deletions.
diff --git a/test/Confluent.Kafka.IntegrationTests/Tests/AdminClient_AlterConfigs.cs b/test/Confluent.Kafka.IntegrationTests/Tests/AdminClient_AlterConfigs.cs
@@ -34,13 +34,6 @@ public partial class Tests
         public void AdminClient_AlterConfigs(string bootstrapServers)
         {
             LogToFile("start AdminClient_AlterConfigs");
-            bool skipFlakyTests = semaphoreSkipFlakyTests();
-            if (skipFlakyTests)
-            {
-                LogToFile("Skipping AdminClient_AlterConfigs Test on Semaphore due to its flaky nature");
-                return;
-            }
-
             using (var adminClient = new AdminClientBuilder(new AdminClientConfig { BootstrapServers = bootstrapServers }).Build())
             {
                 // 1. create a new topic to play with.
@@ -102,7 +95,7 @@ public void AdminClient_AlterConfigs(string bootstrapServers)
                 {
                     { 
                         new ConfigResource { Name = "0", Type = ResourceType.Broker },
-                        new List<ConfigEntry> { new ConfigEntry { Name="num.network.threads", Value="2" } }
+                        new List<ConfigEntry> { new ConfigEntry { Name="num.network.threads", Value="6" } }
                     }
                 };
                 adminClient.AlterConfigsAsync(toUpdate).Wait();

diff --git a/test/Confluent.Kafka.IntegrationTests/Tests/AdminClient_IncrementalAlterConfigs.cs b/test/Confluent.Kafka.IntegrationTests/Tests/AdminClient_IncrementalAlterConfigs.cs
@@ -102,7 +102,7 @@ public void AdminClient_IncrementalAlterConfigs(string bootstrapServers)
                 {
                     { 
                         new ConfigResource { Name = "0", Type = ResourceType.Broker },
-                        new List<ConfigEntry> { new ConfigEntry { Name = "num.network.threads", Value = "2" , IncrementalOperation = AlterConfigOpType.Set } }
+                        new List<ConfigEntry> { new ConfigEntry { Name = "num.network.threads", Value = "6" , IncrementalOperation = AlterConfigOpType.Set } }
                     }
                 };
                 adminClient.IncrementalAlterConfigsAsync(toUpdate).Wait();