3 if [[ -z "$KAFKA_PORT" ]]; then
8 if [[ -z "$KAFKA_ADVERTISED_PORT" && \
9 -z "$KAFKA_LISTENERS" && \
10 -z "$KAFKA_ADVERTISED_LISTENERS" && \
11 -S /var/run/docker.sock ]]; then
12 export KAFKA_ADVERTISED_PORT=$(docker port `hostname` $KAFKA_PORT | sed -r "s/.*:(.*)/\1/g")
14 if [[ -z "$KAFKA_BROKER_ID" ]]; then
15 if [[ -n "$BROKER_ID_COMMAND" ]]; then
16 export KAFKA_BROKER_ID=$(eval $BROKER_ID_COMMAND)
18 # By default auto allocate broker ID
19 export KAFKA_BROKER_ID=-1
22 if [[ -z "$KAFKA_LOG_DIRS" ]]; then
23 export KAFKA_LOG_DIRS="/kafka/kafka-logs-$HOSTNAME"
25 if [[ -z "$KAFKA_ZOOKEEPER_CONNECT" ]]; then
26 export KAFKA_ZOOKEEPER_CONNECT=$(env | grep ZK.*PORT_2181_TCP= | sed -e 's|.*tcp://||' | paste -sd ,)
29 if [[ -n "$KAFKA_HEAP_OPTS" ]]; then
30 sed -r -i "s/(export KAFKA_HEAP_OPTS)=\"(.*)\"/\1=\"$KAFKA_HEAP_OPTS\"/g" $KAFKA_HOME/bin/kafka-server-start.sh
34 if [[ -z "$KAFKA_ADVERTISED_HOST_NAME" && -n "$HOSTNAME_COMMAND" ]]; then
35 export KAFKA_ADVERTISED_HOST_NAME=$(eval $HOSTNAME_COMMAND)
38 #if [[ -n "$KAFKA_LISTENER_SECURITY_PROTOCOL_MAP" ]]; then
39 # if [[ -n "$KAFKA_ADVERTISED_PORT" && -n "$KAFKA_ADVERTISED_PROTOCOL_NAME" ]]; then
40 # export KAFKA_ADVERTISED_LISTENERS="${KAFKA_ADVERTISED_PROTOCOL_NAME}://${KAFKA_ADVERTISED_HOST_NAME-}:${KAFKA_ADVERTISED_PORT}"
41 # export KAFKA_LISTENERS="$KAFKA_ADVERTISED_PROTOCOL_NAME://:$KAFKA_ADVERTISED_PORT"
44 if [[ -z "$KAFKA_PROTOCOL_NAME" ]]; then
45 export KAFKA_PROTOCOL_NAME="${KAFKA_ADVERTISED_PROTOCOL_NAME}"
48 if [[ -n "$KAFKA_PORT" && -n "$KAFKA_PROTOCOL_NAME" ]]; then
49 export ADD_LISTENER="${KAFKA_PROTOCOL_NAME}://${KAFKA_HOST_NAME-}:${KAFKA_PORT}"
52 if [[ -z "$KAFKA_INTER_BROKER_LISTENER_NAME" ]]; then
53 export KAFKA_INTER_BROKER_LISTENER_NAME=$KAFKA_PROTOCOL_NAME
57 # export KAFKA_ADVERTISED_LISTENERS="PLAINTEXT://${KAFKA_ADVERTISED_HOST_NAME-}:${KAFKA_ADVERTISED_PORT-$KAFKA_PORT}"
58 # export KAFKA_LISTENERS="PLAINTEXT://${KAFKA_HOST_NAME-}:${KAFKA_PORT-9092}"
61 #if [[ -n "$ADD_LISTENER" && -n "$KAFKA_LISTENERS" ]]; then
62 # export KAFKA_LISTENERS="${KAFKA_LISTENERS},${ADD_LISTENER}"
65 #if [[ -n "$ADD_LISTENER" && -z "$KAFKA_LISTENERS" ]]; then
66 # export KAFKA_LISTENERS="${ADD_LISTENER}"
69 #if [[ -n "$ADD_LISTENER" && -n "$KAFKA_ADVERTISED_LISTENERS" ]]; then
70 # export KAFKA_ADVERTISED_LISTENERS="${KAFKA_ADVERTISED_LISTENERS},${ADD_LISTENER}"
73 #if [[ -n "$ADD_LISTENER" && -z "$KAFKA_ADVERTISED_LISTENERS" ]]; then
74 # export KAFKA_ADVERTISED_LISTENERS="${ADD_LISTENER}"
77 if [[ -n "$KAFKA_INTER_BROKER_LISTENER_NAME" && ! "$KAFKA_INTER_BROKER_LISTENER_NAME"X = "$KAFKA_PROTOCOL_NAME"X ]]; then
78 if [[ -n "$KAFKA_INTER_BROKER_PORT" ]]; then
79 export KAFKA_INTER_BROKER_PORT=$(( $KAFKA_PORT + 1 ))
81 #export INTER_BROKER_LISTENER="${KAFKA_INTER_BROKER_LISTENER_NAME}://:${KAFKA_INTER_BROKER_PORT}"
82 #export KAFKA_LISTENERS="${KAFKA_LISTENERS},${INTER_BROKER_LISTENER}"
83 #export KAFKA_ADVERTISED_LISTENERS="${KAFKA_ADVERTISED_LISTENERS},${INTER_BROKER_LISTENER}"
84 unset KAFKA_INTER_BROKER_PORT
85 unset KAFKA_SECURITY_INTER_BROKER_PROTOCOL
86 unset INTER_BROKER_LISTENER
89 if [[ -n "$RACK_COMMAND" && -z "$KAFKA_BROKER_RACK" ]]; then
90 export KAFKA_BROKER_RACK=$(eval $RACK_COMMAND)
93 #Issue newline to config file in case there is not one already
94 echo -e "\n" >> $KAFKA_HOME/config/server.properties
96 unset KAFKA_CREATE_TOPICS
97 unset KAFKA_ADVERTISED_PROTOCOL_NAME
98 unset KAFKA_PROTOCOL_NAME
100 if [[ -n "$KAFKA_ADVERTISED_LISTENERS" ]]; then
101 unset KAFKA_ADVERTISED_PORT
102 unset KAFKA_ADVERTISED_HOST_NAME
105 if [[ -n "$KAFKA_LISTENERS" ]]; then
107 unset KAFKA_HOST_NAME
112 if [[ $VAR =~ ^KAFKA_ && ! $VAR =~ ^KAFKA_HOME ]]; then
113 kafka_name=`echo "$VAR" | sed -r "s/KAFKA_(.*)=.*/\1/g" | tr '[:upper:]' '[:lower:]' | tr _ .`
114 env_var=`echo "$VAR" | sed -r "s/(.*)=.*/\1/g"`
115 if egrep -q "(^|^#)$kafka_name=" $KAFKA_HOME/config/server.properties; then
116 sed -r -i "s@(^|^#)($kafka_name)=(.*)@\2=${!env_var}@g" $KAFKA_HOME/config/server.properties #note that no config values may contain an '@' char
118 echo "$kafka_name=${!env_var}" >> $KAFKA_HOME/config/server.properties
122 if [[ $VAR =~ ^LOG4J_ ]]; then
123 log4j_name=`echo "$VAR" | sed -r "s/(LOG4J_.*)=.*/\1/g" | tr '[:upper:]' '[:lower:]' | tr _ .`
124 log4j_env=`echo "$VAR" | sed -r "s/(.*)=.*/\1/g"`
125 if egrep -q "(^|^#)$log4j_name=" $KAFKA_HOME/config/log4j.properties; then
126 sed -r -i "s@(^|^#)($log4j_name)=(.*)@\2=${!log4j_env}@g" $KAFKA_HOME/config/log4j.properties #note that no config values may contain an '@' char
128 echo "$log4j_name=${!log4j_env}" >> $KAFKA_HOME/config/log4j.properties
133 if [[ -n "$CUSTOM_INIT_SCRIPT" ]] ; then
134 eval $CUSTOM_INIT_SCRIPT
136 cp /tmp/kafka11aaf-jar-with-dependencies.jar $KAFKA_HOME/libs
137 cp /tmp/org.onap.dmaap.mr.keyfile $KAFKA_HOME/config
138 cp /tmp/org.onap.dmaap.mr.trust.jks $KAFKA_HOME/config
139 cp /tmp/org.onap.dmaap.mr.p12 $KAFKA_HOME/config
140 cp /tmp/kafka_server_jaas.conf $KAFKA_HOME/config
141 cp /tmp/cadi.properties $KAFKA_HOME/config
142 export KAFKA_OPTS="-Djava.security.auth.login.config=$KAFKA_HOME/config/kafka_server_jaas.conf"
146 cp /tmp/kafka-run-class.sh /opt/kafka/bin
147 java -jar /tmp/dmaapMMAgent.jar