From f5cea3d5ba7011eb2909008ab6dd2b80fc261f8f Mon Sep 17 00:00:00 2001 From: Tom Bentley Date: Thu, 12 Oct 2017 12:31:56 +0100 Subject: [PATCH] MINOR: Use OS-assigned port, in case 9092 is already bound --- .../kafka/streams/integration/ResetIntegrationWithSslTest.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/streams/src/test/java/org/apache/kafka/streams/integration/ResetIntegrationWithSslTest.java b/streams/src/test/java/org/apache/kafka/streams/integration/ResetIntegrationWithSslTest.java index d018225bb8cf..f0dd0c8796fb 100644 --- a/streams/src/test/java/org/apache/kafka/streams/integration/ResetIntegrationWithSslTest.java +++ b/streams/src/test/java/org/apache/kafka/streams/integration/ResetIntegrationWithSslTest.java @@ -57,7 +57,7 @@ public class ResetIntegrationWithSslTest extends AbstractResetIntegrationTest { // expiration of connections by the brokers to avoid errors when `AdminClient` sends requests after potentially // very long sleep times props.put(KafkaConfig$.MODULE$.ConnectionsMaxIdleMsProp(), -1L); - props.put(KafkaConfig$.MODULE$.ListenersProp(), "SSL://localhost:9092"); + props.put(KafkaConfig$.MODULE$.ListenersProp(), "SSL://localhost:0"); props.put(KafkaConfig$.MODULE$.InterBrokerListenerNameProp(), "SSL"); props.putAll(sslConfig); // we align time to seconds to get clean window boundaries and thus ensure the same result for each run