Increase number of network threads (#2081)

* Increase number of network
threads to avoid disconnections from
broker 0

* Same fix for AlterConfig integration test

Author: emasab

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();

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();