aboutsummaryrefslogtreecommitdiff
path: root/kafka
diff options
context:
space:
mode:
authorStaffan Olsson <staffan@repos.se>2018-01-08 13:21:59 +0100
committerStaffan Olsson <staffan@repos.se>2018-01-08 13:21:59 +0100
commitf76e192ab4cdd5d0cc833690276a5eb3e7aa715d (patch)
treead1a10fe3d2e8ba2c0cca8e150520b2f0a1da860 /kafka
parent8811b0264591fba3299ace4d537db09613bacb56 (diff)
downloadkubernetes-kafka-f76e192ab4cdd5d0cc833690276a5eb3e7aa715d.tar.gz
kubernetes-kafka-f76e192ab4cdd5d0cc833690276a5eb3e7aa715d.tar.bz2
kubernetes-kafka-f76e192ab4cdd5d0cc833690276a5eb3e7aa715d.zip
Sets other useful labels, for #78 and #56
Diffstat (limited to 'kafka')
-rw-r--r--kafka/10broker-config.yml7
1 files changed, 5 insertions, 2 deletions
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
}