Do not nullify the cluster reference on the embedded kafka service.
This ensures that the embedded kafka service is compatible with JUnit's 5 class life cycle
@@ -94,7 +94,6 @@ public class EmbeddedKafkaService implements KafkaService {
if (started) {
cluster.stop();
- cluster = null;
started = false;
}
}
