1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
|
#!/bin/bash
set -eu
set -o pipefail
KAFKA_VERSION="${KAFKA_VERSION:-3.6.2}"
KAFKA_HOME="/opt/kafka-${KAFKA_VERSION}"
if [ ! -d "${KAFKA_HOME}" ]; then
echo 'Error: KAFKA_VERSION '$KAFKA_VERSION' not available in this image at '$KAFKA_HOME
exit 1
fi
cd "${KAFKA_HOME}" || exit 1
# discard all empty/commented lines from default config and copy to /tmp
sed -e '/^#/d' -e '/^$/d' config/server.properties >/tmp/server.properties
echo "########################################################################" >>/tmp/server.properties
# emulate kafka_configure_from_environment_variables from bitnami/bitnami-docker-kafka
for var in "${!KAFKA_CFG_@}"; do
key="$(echo "$var" | sed -e 's/^KAFKA_CFG_//g' -e 's/_/\./g' -e 's/.*/\L&/')"
sed -e '/^'$key'/d' -i"" /tmp/server.properties
value="${!var}"
echo "$key=$value" >>/tmp/server.properties
done
sort /tmp/server.properties
exec bin/kafka-server-start.sh /tmp/server.properties
|
