Kafka Test Support

-minor change in KafkaTestSupport to add a getter for KafkaServer.
This commit is contained in:
Soby Chacko
2016-01-27 17:36:37 -05:00
parent e792b0e347
commit 60e44b530d

View File

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