[jira] [Created] (KAFKA-16473) KafkaDockerWrapper uses wrong cluster ID when formatting log dir

["Sebastian Marsching (Jira)" <ji...@apache.org>]

Sebastian Marsching created KAFKA-16473:
-------------------------------------------

             Summary: KafkaDockerWrapper uses wrong cluster ID when formatting log dir
                 Key: KAFKA-16473
                 URL: https://issues.apache.org/jira/browse/KAFKA-16473
             Project: Kafka
          Issue Type: Bug
    Affects Versions: 3.7.0
            Reporter: Sebastian Marsching


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.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)