kiloeyes/vagrant/onvm/scripts/install-kafka.sh

29 lines
923 B
Bash

#!/usr/bin/env bash
# $1 sys_password
# $2 public ip eth0
source /onvm/scripts/ini-config
eval $(parse_yaml '/onvm/conf/nodes.conf.yml' 'leap_')
# Java is required, install java first
source /onvm/scripts/install-java.sh
if [ -f /leapbin/kafka_*-0.9.0.0.tgz ]; then
tar -zxf /leapbin/kafka_*-0.9.0.0.tgz -C /opt
mv /opt/kafka_*-0.9.0.0 /opt/kafka_0.9.0.0
echo '# Changes made by kiloeyes installation...' >> /opt/kafka_0.9.0.0/config/server.properties
echo 'auto.create.topics.enable=true' >> /opt/kafka_0.9.0.0/config/server.properties
echo "host.name=$2" >> /opt/kafka_0.9.0.0/config/server.properties
/opt/kafka_0.9.0.0/bin/zookeeper-server-start.sh -daemon /opt/kafka_0.9.0.0/config/zookeeper.properties
sleep 2
/opt/kafka_0.9.0.0/bin/kafka-server-start.sh -daemon /opt/kafka_0.9.0.0/config/server.properties
echo 'Kafka install is now complete!'
else
echo 'Kafka binary was not found!'
fi