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)
