[kafka] branch trunk updated: MINOR: Fix Transient test failure SslTransportLayerTest.testNetworkThreadTimeRecorded (#5597)

[rs...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

rsivaram pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new cb48466  MINOR: Fix Transient test failure SslTransportLayerTest.testNetworkThreadTimeRecorded (#5597)
cb48466 is described below

commit cb484666f2474747538585ed3b986aed5b02830d
Author: Manikumar Reddy O <ma...@gmail.com>
AuthorDate: Mon Sep 3 21:19:48 2018 +0530

    MINOR: Fix Transient test failure SslTransportLayerTest.testNetworkThreadTimeRecorded (#5597)
---
 .../src/test/java/org/apache/kafka/common/network/NioEchoServer.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/clients/src/test/java/org/apache/kafka/common/network/NioEchoServer.java b/clients/src/test/java/org/apache/kafka/common/network/NioEchoServer.java
index bd212fd..7996e59 100644
--- a/clients/src/test/java/org/apache/kafka/common/network/NioEchoServer.java
+++ b/clients/src/test/java/org/apache/kafka/common/network/NioEchoServer.java
@@ -95,7 +95,7 @@ public class NioEchoServer extends Thread {
         if (channelBuilder == null)
             channelBuilder = ChannelBuilders.serverChannelBuilder(listenerName, false, securityProtocol, config, credentialCache, tokenCache);
         this.metrics = new Metrics();
-        this.selector = new Selector(5000, failedAuthenticationDelayMs, metrics, time, "MetricGroup", channelBuilder, new LogContext());
+        this.selector = new Selector(10000, failedAuthenticationDelayMs, metrics, time, "MetricGroup", channelBuilder, new LogContext());
         acceptorThread = new AcceptorThread();
     }