You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ij...@apache.org on 2017/10/12 13:23:22 UTC
kafka git commit: MINOR: Use port 0 in ResetIntegrationWithSslTest
Repository: kafka
Updated Branches:
refs/heads/trunk 57839e17c -> f8ffb67ad
MINOR: Use port 0 in ResetIntegrationWithSslTest
I found this by running the tests while I happened to
have a kafka broker running.
Author: Tom Bentley <tb...@redhat.com>
Reviewers: Ismael Juma <is...@juma.me.uk>
Closes #4065 from tombentley/MINOR-random-port
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/f8ffb67a
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/f8ffb67a
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/f8ffb67a
Branch: refs/heads/trunk
Commit: f8ffb67ad6e630a2e3350f74c108154267b85c98
Parents: 57839e1
Author: Tom Bentley <tb...@redhat.com>
Authored: Thu Oct 12 14:22:53 2017 +0100
Committer: Ismael Juma <is...@juma.me.uk>
Committed: Thu Oct 12 14:23:03 2017 +0100
----------------------------------------------------------------------
.../kafka/streams/integration/ResetIntegrationWithSslTest.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kafka/blob/f8ffb67a/streams/src/test/java/org/apache/kafka/streams/integration/ResetIntegrationWithSslTest.java
----------------------------------------------------------------------
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 d018225..f0dd0c8 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