super("KAFKA");
this.embedded = embedded;
log.info(String.format("Testing with %s Kafka broker", embedded ? "embedded" : "external"));
}
public KafkaServer getKafkaServer() {
<BUG>return kafkaServer;
</BUG>
}
public String getZkConnectString() {
<BUG>if (embedded) {

return zookeeper.getConnectString();
</BUG>
}

super("KAFKA");
this.embedded = embedded;
log.info(String.format("Testing with %s Kafka broker", embedded ? "embedded" : "external"));
}
public KafkaServer getKafkaServer() {
return this.kafkaServer;
}
public String getZkConnectString() {
if (this.embedded) {
return this.zookeeper.getConnectString();
}
