throw new RuntimeException("Kafka server not available");
}
}
@Override
protected void cleanupResource() throws Exception {
<BUG>if (embedded) {
</BUG>
try {
<BUG>kafkaServer.shutdown();
</BUG>
}

throw new RuntimeException("Kafka server not available");
}
}
}
else {
throw new RuntimeException("Kafka server not available");
}
}
@Override
protected void cleanupResource() throws Exception {
if (this.embedded) {
try {
this.kafkaServer.shutdown();
}
