diff --git a/applications/sink/zeromq-sink/src/test/java/org/springframework/cloud/stream/app/sink/zeromq/ZeroMqSinkTests.java b/applications/sink/zeromq-sink/src/test/java/org/springframework/cloud/stream/app/sink/zeromq/ZeroMqSinkTests.java
index b0609998..140c4e17 100644
--- a/applications/sink/zeromq-sink/src/test/java/org/springframework/cloud/stream/app/sink/zeromq/ZeroMqSinkTests.java
+++ b/applications/sink/zeromq-sink/src/test/java/org/springframework/cloud/stream/app/sink/zeromq/ZeroMqSinkTests.java
@@ -17,6 +17,7 @@
 package org.springframework.cloud.stream.app.sink.zeromq;
 
 import org.junit.jupiter.api.AfterAll;
+import org.junit.jupiter.api.Disabled;
 import org.junit.jupiter.api.Test;
 import org.zeromq.SocketType;
 import org.zeromq.ZContext;
@@ -44,6 +45,7 @@ import static org.assertj.core.api.Assertions.assertThat;
  *
  * @since 3.1.0
  */
+@Disabled("PUB/SUB is async and we can't guess when subscriber is ready before sending a message")
 public class ZeroMqSinkTests {
 
 	private static final ZContext CONTEXT = new ZContext();
diff --git a/functions/consumer/zeromq-consumer/src/test/java/org/springframework/cloud/fn/consumer/zeromq/ZeroMqConsumerConfigurationTests.java b/functions/consumer/zeromq-consumer/src/test/java/org/springframework/cloud/fn/consumer/zeromq/ZeroMqConsumerConfigurationTests.java
index 7224275b..9152930f 100644
--- a/functions/consumer/zeromq-consumer/src/test/java/org/springframework/cloud/fn/consumer/zeromq/ZeroMqConsumerConfigurationTests.java
+++ b/functions/consumer/zeromq-consumer/src/test/java/org/springframework/cloud/fn/consumer/zeromq/ZeroMqConsumerConfigurationTests.java
@@ -20,6 +20,7 @@ import java.util.function.Function;
 
 import org.junit.jupiter.api.AfterAll;
 import org.junit.jupiter.api.BeforeAll;
+import org.junit.jupiter.api.Disabled;
 import org.junit.jupiter.api.Test;
 import org.zeromq.SocketType;
 import org.zeromq.ZContext;
@@ -44,6 +45,7 @@ import static org.assertj.core.api.Assertions.assertThat;
  */
 @SpringBootTest(properties =  "zeromq.consumer.topic='test-topic'")
 @DirtiesContext
+@Disabled("PUB/SUB is async and we can't guess when subscriber is ready before sending a message")
 public class ZeroMqConsumerConfigurationTests {
 
 	private static final ZContext CONTEXT = new ZContext();