31 lines
988 B
Bash
Executable File
31 lines
988 B
Bash
Executable File
#!/bin/bash
|
|
. /opt/bitnami/base/functions
|
|
. /opt/bitnami/base/helpers
|
|
|
|
|
|
USER=kafka
|
|
KAFKA_HOME="/opt/bitnami/kafka"
|
|
START_COMMAND="${KAFKA_HOME}/bin/kafka-server-start.sh -daemon ${KAFKA_HOME}/config/server.properties && ps ax | grep -i 'java.*kafka' | grep -v grep | awk '{print \$1}' > ${KAFKA_HOME}/tmp/kafka.pid && tail -f ${KAFKA_HOME}/logs/server.log"
|
|
|
|
if [[ -z "$KAFKA_BROKER_ID" ]]; then
|
|
if [[ -n "$BROKER_ID_COMMAND" ]]; then
|
|
export KAFKA_BROKER_ID=$(eval $BROKER_ID_COMMAND)
|
|
else
|
|
# By default auto allocate broker ID
|
|
export KAFKA_BROKER_ID=-1
|
|
fi
|
|
fi
|
|
|
|
if [[ "$KAFKA_LISTENERS" =~ SASL ]]; then
|
|
export KAFKA_OPTS="-Djava.security.auth.login.config=${KAFKA_HOME}/conf/kafka_jaas.conf"
|
|
fi
|
|
|
|
# If container is started as `root` user
|
|
if [ $EUID -eq 0 ]; then
|
|
gosu ${USER} touch ${KAFKA_HOME}/logs/server.log
|
|
exec gosu ${USER} bash -c "${START_COMMAND}"
|
|
else
|
|
touch ${KAFKA_HOME}/logs/server.log
|
|
exec bash -c "${START_COMMAND}"
|
|
fi
|