From 60e44b530d99d357c5b3b19e2f2b3b505249b382 Mon Sep 17 00:00:00 2001
From: Soby Chacko <schacko@pivotal.io>
Date: Wed, 27 Jan 2016 17:36:37 -0500
Subject: [PATCH] Kafka Test Support

-minor change in KafkaTestSupport to add a getter for KafkaServer.
---
 .../cloud/stream/test/junit/kafka/KafkaTestSupport.java       | 4 ++++
 1 file changed, 4 insertions(+)

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();