diff --git a/spring-cloud-stream-test-support-internal/src/main/java/org/springframework/cloud/stream/test/junit/kafka/KafkaTestSupport.java b/spring-cloud-stream-test-support-internal/src/main/java/org/springframework/cloud/stream/test/junit/kafka/KafkaTestSupport.java
index b6ef10a14..e86dc1454 100644
--- a/spring-cloud-stream-test-support-internal/src/main/java/org/springframework/cloud/stream/test/junit/kafka/KafkaTestSupport.java
+++ b/spring-cloud-stream-test-support-internal/src/main/java/org/springframework/cloud/stream/test/junit/kafka/KafkaTestSupport.java
@@ -76,6 +76,10 @@ public class KafkaTestSupport extends AbstractExternalResourceTestSupport<String
 		super("KAFKA");
 	}
 
+	public KafkaServer getKafkaServer() {
+		return kafkaServer;
+	}
+
 	public String getZkConnectString() {
 		if (embedded) {
 			return zookeeper.getConnectString();