diff --git a/kafka/2.1.0/start_kafka.sh b/kafka/2.1.0/start_kafka.sh
index ef10f7a..e08e9b2 100755
--- a/kafka/2.1.0/start_kafka.sh
+++ b/kafka/2.1.0/start_kafka.sh
@@ -1,10 +1,21 @@
 #!/bin/bash
 
-## Overide default configuration files
 : ${EXTRA_CONF_DIR:=/config/kafka}
 
+## Overide default configuration files
 if [ -d "$EXTRA_CONF_DIR" ]; then
 	cp $EXTRA_CONF_DIR/* /usr/local/kafka/config
 fi
 
+
+if ! [[ -z "${BROKER_ID}" ]]; then
+	sed -i '/broker.id=/d' /usr/local/kafka/config/server.properties
+	echo "broker.id=$BROKER_ID" >> /usr/local/kafka/config/server.properties
+fi
+
+if ! [[ -z "${ZOOKEEPER_CONNECT}" ]]; then
+	sed -i '/zookeeper.connect=/d' /usr/local/kafka/config/server.properties
+	echo "zookeeper.connect=$ZOOKEEPER_CONNECT" >> /usr/local/kafka/config/server.properties
+fi
+
 bash /usr/local/kafka/bin/kafka-server-start.sh /usr/local/kafka/config/server.properties