diff --git a/core/src/test/scala/unit/kafka/network/ConnectionQuotasTest.scala b/core/src/test/scala/unit/kafka/network/ConnectionQuotasTest.scala index 725435cc67d5b..0bddb2b8d633d 100644 --- a/core/src/test/scala/unit/kafka/network/ConnectionQuotasTest.scala +++ b/core/src/test/scala/unit/kafka/network/ConnectionQuotasTest.scala @@ -407,7 +407,7 @@ class ConnectionQuotasTest { val futures = listeners.values.map { listener => executor.submit((() => // epsilon is set to account for the worst-case where the measurement is taken just before or after the quota window - acceptConnectionsAndVerifyRate(connectionQuotas, listener, connectionsPerListener, connCreateIntervalMs, listenerRateLimit, 7)): Runnable) + acceptConnectionsAndVerifyRate(connectionQuotas, listener, connectionsPerListener, connCreateIntervalMs, listenerRateLimit, 8)): Runnable) } futures.foreach(_.get(30, TimeUnit.SECONDS))