From 196634fb1d3ac22ca3456bdeeb8b309a32ae4f35 Mon Sep 17 00:00:00 2001 From: Andras Katona Date: Thu, 8 Aug 2024 15:50:37 +0200 Subject: [PATCH] Set Embedded Zookeeper listen on 127.0.0.1 --- .../metricsreporter/utils/CCEmbeddedZookeeper.java | 7 ++----- 1 file changed, 2 insertions(+), 5 deletions(-) diff --git a/cruise-control-metrics-reporter/src/test/java/com/linkedin/kafka/cruisecontrol/metricsreporter/utils/CCEmbeddedZookeeper.java b/cruise-control-metrics-reporter/src/test/java/com/linkedin/kafka/cruisecontrol/metricsreporter/utils/CCEmbeddedZookeeper.java index fadcf55c0..12581b251 100644 --- a/cruise-control-metrics-reporter/src/test/java/com/linkedin/kafka/cruisecontrol/metricsreporter/utils/CCEmbeddedZookeeper.java +++ b/cruise-control-metrics-reporter/src/test/java/com/linkedin/kafka/cruisecontrol/metricsreporter/utils/CCEmbeddedZookeeper.java @@ -5,7 +5,6 @@ package com.linkedin.kafka.cruisecontrol.metricsreporter.utils; import java.io.File; -import java.net.InetAddress; import java.net.InetSocketAddress; import java.util.concurrent.CountDownLatch; import org.apache.zookeeper.server.NIOServerCnxnFactory; @@ -14,7 +13,7 @@ public class CCEmbeddedZookeeper implements AutoCloseable { - private final String _hostAddress; + private final String _hostAddress = "127.0.0.1"; private final int _port; private final ZooKeeperServer _zk; private final ServerCnxnFactory _cnxnFactory; @@ -27,9 +26,7 @@ public CCEmbeddedZookeeper() { File logDir = CCKafkaTestUtils.newTempDir(); _zk = new ZooKeeperServer(snapshotDir, logDir, tickTime); _cnxnFactory = new NIOServerCnxnFactory(); - InetAddress localHost = InetAddress.getLocalHost(); - _hostAddress = localHost.getHostAddress(); - InetSocketAddress bindAddress = new InetSocketAddress(localHost, 0); + InetSocketAddress bindAddress = new InetSocketAddress(_hostAddress, 0); _cnxnFactory.configure(bindAddress, 0); _cnxnFactory.startup(_zk); _port = _zk.getClientPort();