Major Description
There is a bug in KafkaDockerWrapper, that causes Some(<value of CLUSTER_ID environment variable>) to be used when formatting the log dir when Kafka is started for the first time inside a Docker container.
More specifically, the problem is in formatStorageCmd: The code uses env.get("CLUSTER_ID"), but this returns an Option not a String.
The code should instead check whether the environment variable is set, raising an exception if it is not set.
Attachments
Issue Links
- links to