[
https://issues.apache.org/jira/browse/KAFKA-16473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834021#comment-17834021
]
Sebastian Marsching commented on KAFKA-16473:
---------------------------------------------
[~brandboat] The PR is now available at
[https://github.com/apache/kafka/pull/15658].
> 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)
