diff --git a/clients/src/test/java/org/apache/kafka/clients/ClientUtilsTest.java b/clients/src/test/java/org/apache/kafka/clients/ClientUtilsTest.java index 572896f56bd11..5f545b901d911 100644 --- a/clients/src/test/java/org/apache/kafka/clients/ClientUtilsTest.java +++ b/clients/src/test/java/org/apache/kafka/clients/ClientUtilsTest.java @@ -26,6 +26,8 @@ import static org.junit.Assert.assertEquals; import static org.junit.Assert.assertFalse; import static org.junit.Assert.assertTrue; + +import org.junit.Ignore; import org.junit.Test; public class ClientUtilsTest { @@ -106,6 +108,7 @@ public void testResolveDnsLookup() throws UnknownHostException { } @Test + @Ignore public void testResolveDnsLookupAllIps() throws UnknownHostException { assertTrue(ClientUtils.resolve("kafka.apache.org", ClientDnsLookup.USE_ALL_DNS_IPS).size() > 1); } diff --git a/clients/src/test/java/org/apache/kafka/clients/ClusterConnectionStatesTest.java b/clients/src/test/java/org/apache/kafka/clients/ClusterConnectionStatesTest.java index 0d805d80628aa..3478eeefe0c11 100644 --- a/clients/src/test/java/org/apache/kafka/clients/ClusterConnectionStatesTest.java +++ b/clients/src/test/java/org/apache/kafka/clients/ClusterConnectionStatesTest.java @@ -255,6 +255,7 @@ public void testSingleIPWithUseAll() throws UnknownHostException { assertSame(currAddress, connectionStates.currentAddress(nodeId1)); } + @Ignore @Test public void testMultipleIPsWithDefault() throws UnknownHostException { assertTrue(ClientUtils.resolve(hostTwoIps, ClientDnsLookup.USE_ALL_DNS_IPS).size() > 1); @@ -281,6 +282,7 @@ public void testMultipleIPsWithUseAll() throws UnknownHostException { assertNotSame(addr1, addr3); } + @Ignore @Test public void testHostResolveChange() throws UnknownHostException, ReflectiveOperationException { assertTrue(ClientUtils.resolve(hostTwoIps, ClientDnsLookup.USE_ALL_DNS_IPS).size() > 1);