[ https://issues.apache.org/jira/browse/KAFKA-16473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17833999#comment-17833999 ]
Sebastian Marsching commented on KAFKA-16473: --------------------------------------------- I am currently working on a PR that should address this issue. I would appreciate a review of that PR, though. > 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 > Priority: Major > > 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)