From f76e192ab4cdd5d0cc833690276a5eb3e7aa715d Mon Sep 17 00:00:00 2001 From: Staffan Olsson Date: Mon, 8 Jan 2018 13:21:59 +0100 Subject: Sets other useful labels, for #78 and #56 --- kafka/10broker-config.yml | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) (limited to 'kafka') diff --git a/kafka/10broker-config.yml b/kafka/10broker-config.yml index d11eeaf..55a0c3b 100644 --- a/kafka/10broker-config.yml +++ b/kafka/10broker-config.yml @@ -21,6 +21,7 @@ data: sed -i "s/#init#broker.rack=#init#/#init#broker.rack=# zone label not found for node $NODE_NAME/" /etc/kafka/server.properties else sed -i "s/#init#broker.rack=#init#/broker.rack=$ZONE/" /etc/kafka/server.properties + kubectl -n $POD_NAMESPACE label pod $POD_NAME kafka-broker-rack=$ZONE fi kubectl -n $POD_NAMESPACE label pod $POD_NAME kafka-broker-id=$KAFKA_BROKER_ID @@ -29,8 +30,10 @@ data: if [ $? -ne 0 ]; then echo "Outside (i.e. cluster-external access) host lookup command failed" else - OUTSIDE_HOST=${OUTSIDE_HOST}:3240${KAFKA_BROKER_ID} - sed -i "s|#init#advertised.listeners=OUTSIDE://#init#|advertised.listeners=OUTSIDE://${OUTSIDE_HOST}|" /etc/kafka/server.properties + OUTSIDE_PORT=3240${KAFKA_BROKER_ID} + sed -i "s|#init#advertised.listeners=OUTSIDE://#init#|advertised.listeners=OUTSIDE://${OUTSIDE_HOST}:${OUTSIDE_PORT}|" /etc/kafka/server.properties + kubectl -n $POD_NAMESPACE label pod $POD_NAME kafka-listener-outside-host=$OUTSIDE_HOST + kubectl -n $POD_NAMESPACE label pod $POD_NAME kafka-listener-outside-port=$OUTSIDE_PORT fi } -- cgit v1.2.3