From 07a0b4ba268d7b00576e41333021f8827c1eca4e Mon Sep 17 00:00:00 2001 From: Manikumar Reddy Date: Thu, 5 Apr 2018 00:18:28 +0530 Subject: [PATCH 1/2] KAFKA-6741: Increase Selector's idle connection timeout of testNetworkThreadTimeRecorded() test --- .../org/apache/kafka/common/network/SslTransportLayerTest.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/clients/src/test/java/org/apache/kafka/common/network/SslTransportLayerTest.java b/clients/src/test/java/org/apache/kafka/common/network/SslTransportLayerTest.java index f54f490ec0a88..1bdfbd0ff65f8 100644 --- a/clients/src/test/java/org/apache/kafka/common/network/SslTransportLayerTest.java +++ b/clients/src/test/java/org/apache/kafka/common/network/SslTransportLayerTest.java @@ -635,7 +635,7 @@ public void testApplicationBufferResize() throws Exception { @Test public void testNetworkThreadTimeRecorded() throws Exception { selector.close(); - this.selector = new Selector(NetworkReceive.UNLIMITED, 5000, new Metrics(), Time.SYSTEM, + this.selector = new Selector(NetworkReceive.UNLIMITED, 10000, new Metrics(), Time.SYSTEM, "MetricGroup", new HashMap(), false, true, channelBuilder, MemoryPool.NONE, new LogContext()); String node = "0"; From 3f4a522a2f1f2b83b26cb11f5fbd6680bf1b37ab Mon Sep 17 00:00:00 2001 From: Manikumar Reddy Date: Thu, 5 Apr 2018 13:03:09 +0530 Subject: [PATCH 2/2] KAFKA-6741: Disable Selector idle connection timeout for testNetworkThreadTimeRecorded() test --- .../org/apache/kafka/common/network/SslTransportLayerTest.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/clients/src/test/java/org/apache/kafka/common/network/SslTransportLayerTest.java b/clients/src/test/java/org/apache/kafka/common/network/SslTransportLayerTest.java index 1bdfbd0ff65f8..d6b4bac48d8e3 100644 --- a/clients/src/test/java/org/apache/kafka/common/network/SslTransportLayerTest.java +++ b/clients/src/test/java/org/apache/kafka/common/network/SslTransportLayerTest.java @@ -635,7 +635,7 @@ public void testApplicationBufferResize() throws Exception { @Test public void testNetworkThreadTimeRecorded() throws Exception { selector.close(); - this.selector = new Selector(NetworkReceive.UNLIMITED, 10000, new Metrics(), Time.SYSTEM, + this.selector = new Selector(NetworkReceive.UNLIMITED, Selector.NO_IDLE_TIMEOUT_MS, new Metrics(), Time.SYSTEM, "MetricGroup", new HashMap(), false, true, channelBuilder, MemoryPool.NONE, new LogContext()); String node = "0";