diff --git a/spring-cloud-function-samples/function-sample-cloudevent-rsocket/src/test/java/io/spring/cloudevent/DemoApplicationTests.java b/spring-cloud-function-samples/function-sample-cloudevent-rsocket/src/test/java/io/spring/cloudevent/DemoApplicationTests.java
index 90358ace5..e09a46408 100644
--- a/spring-cloud-function-samples/function-sample-cloudevent-rsocket/src/test/java/io/spring/cloudevent/DemoApplicationTests.java
+++ b/spring-cloud-function-samples/function-sample-cloudevent-rsocket/src/test/java/io/spring/cloudevent/DemoApplicationTests.java
@@ -1,5 +1,7 @@
 package io.spring.cloudevent;
 
+import java.net.InetSocketAddress;
+import java.net.Socket;
 import java.util.Collections;
 import java.util.concurrent.ArrayBlockingQueue;
 import java.util.concurrent.TimeUnit;
@@ -64,11 +66,13 @@ public class DemoApplicationTests {
 		@Override
 		public ConditionEvaluationResult evaluateExecutionCondition(ExtensionContext context) {
 			try {
-				KafkaAdminClient.create(Collections.singletonMap("bootstrap.servers", "localhost:9092"));
+				Socket socket = new Socket();
+				socket.connect(new InetSocketAddress("localhost", 9092));
+				socket.close();
 			}
 			catch (Exception e) {
 				System.out.println("Kafka is not available on localhost:9092");
-				return ConditionEvaluationResult.enabled("Kafka is not available on localhost, default port");
+				return ConditionEvaluationResult.disabled("Kafka is not available on localhost, default port");
 			}
 
 			return ConditionEvaluationResult.enabled("All is good");
diff --git a/spring-cloud-function-samples/function-sample-cloudevent-stream/src/test/java/io/spring/cloudevent/DemoApplicationTests.java b/spring-cloud-function-samples/function-sample-cloudevent-stream/src/test/java/io/spring/cloudevent/DemoApplicationTests.java
index c2ec6e012..eb57b7bc6 100644
--- a/spring-cloud-function-samples/function-sample-cloudevent-stream/src/test/java/io/spring/cloudevent/DemoApplicationTests.java
+++ b/spring-cloud-function-samples/function-sample-cloudevent-stream/src/test/java/io/spring/cloudevent/DemoApplicationTests.java
@@ -1,5 +1,7 @@
 package io.spring.cloudevent;
 
+import java.net.InetSocketAddress;
+import java.net.Socket;
 import java.util.Collections;
 import java.util.concurrent.ArrayBlockingQueue;
 import java.util.concurrent.TimeUnit;
@@ -60,11 +62,13 @@ public class DemoApplicationTests {
 			try {
 				new CachingConnectionFactory("localhost").createConnection();
 				try {
-					KafkaAdminClient.create(Collections.singletonMap("bootstrap.servers", "localhost:9092"));
+					Socket socket = new Socket();
+					socket.connect(new InetSocketAddress("localhost", 9092));
+					socket.close();
 				}
 				catch (Exception e) {
 					System.out.println("Kafka is not available on localhost:9092");
-					return ConditionEvaluationResult.enabled("Kafka is not available on localhost, default port");
+					return ConditionEvaluationResult.disabled("Kafka is not available on localhost, default port");
 				}
 			}
 			catch (Exception e) {