标签：bin jdk zookeeper echo usr kafka local
#!/bin/bash
ZK_URL="https://mirrors.tuna.tsinghua.edu.cn/apache/zookeeper/zookeeper-3.6.3/apache-zookeeper-3.6.3-bin.tar.gz"
KAFKA_URL="https://mirrors.tuna.tsinghua.edu.cn/apache/kafka/2.8.1/kafka_2.13-2.8.1.tgz"
NODE1=10.0.0.17
NODE2=10.0.0.27
NODE3=10.0.0.47
HOST=$(hostname -I | awk '{print $1}')
# 加载/etc/os-release，得到变量ID=centos或ID=ubuntu
. /etc/os-release
install_jdk(){
if [ $ID = "centos" ]; then
yum -y install java-1.8.0-openjdk-devel || { echo "install JDK failed"; exit 1; }
elif [ $ID = "ubuntu" ]; then
apt update
apt -y install openjdk-8-jdk || { echo "install JDK failed"; exit 1; }
fi
java -version
}
install_zookeeper() {
wget -P /usr/local/src/ --no-check-certificate $ZK_URL || { echo "download zookeeper failed"; exit 1; }
tar xf /usr/local/src/${ZK_URL##*/} -C /usr/local
ln -s /usr/local/apache-zookeeper-*-bin/ /usr/local/zookeeper
echo 'PATH=/usr/local/zookeeper/bin:$PATH' > /etc/profile.d/zookeeper.sh
. /etc/profile.d/zookeeper.sh
mkdir -p /usr/local/zookeeper/data
echo $ZKID > /usr/local/zookeeper/data/myid
cat > /usr/local/zookeeper/conf/zoo.cfg <<EOF
tickTime=2000
initLimit=10
syncLimit=5
dataDir=/usr/local/zookeeper/data
clientPort=2181
maxCientCnxns=128
autopurge.snapRetainCount=3
autopurge.purgeInterval=24
4lw.commands.whitelist=*
#zookeeper集群
server.1=${NODE1}:2888:3888
server.2=${NODE2}:2888:3888
server.3=${NODE3}:2888:3888
EOF
cat > /lib/systemd/system/zookeeper.service <<EOF
[Unit]
Description=zookeeper.service
After=network.target
[Service]
Type=forking
#Environment=/usr/local/zookeeper
ExecStart=/usr/local/zookeeper/bin/zkServer.sh start
ExecStop=/usr/local/zookeeper/bin/zkServer.sh stop
ExecReload=/usr/local/zookeeper/bin/zkServer.sh restart
[Install]
WantedBy=multi-user.target
EOF
systemctl daemon-reload
systemctl enable --now zookeeper.service
systemctl is-active zookeeper.service
if [ $? -eq 0 ]; then
echo "zookeeper 安装成功"
else
echo "zookeeper 安装失败"
exit 1
fi
}
install_kafka() {
wget -P /usr/local/src --no-check-certificate $KAFKA_URL
tar xf /usr/local/src/${KAFKA_URL##*/} -C /usr/local/
ln -s /usr/local/kafka_*/ /usr/local/kafka
echo 'PATH=/usr/local/kafka/bin:$PATH' > /etc/profile.d/kafka.sh
. /etc/profile.d/kafka.sh
cat > /usr/local/kafka/config/server.properties <<EOF
broker.id=$ZKID
listeners=PLAINTEXT://${HOST}:9092
log.dirs=/usr/local/kafka/data
num.partitions=1
log.retention.hours=168
zookeeper.connect=${NODE1}:2181,${NODE2}:2181,${NODE3}:2181
zookeeper.connection.timeout.ms=6000
EOF
mkdir /usr/local/kafka/data
cat > /lib/systemd/system/kafka.service <<EOF
[Unit]
Description=Apache Kafka
After=network.target
[Service]
Type=simple
#Environment=JAVA_HOME=/data/server/java
#PIDFILE=/usr/local/kafka/kafka.pid
ExecStart=/usr/local/kafka/bin/kafka-server-start.sh /usr/local/kafka/config/server.properties
ExecStop=/bin/kill -TERM \${MAINPID}
Restart=always
RestartSec=20
[Install]
WantedBy=multi-user.target
EOF
systemctl daemon-reload
systemctl enable --now kafka.service
systemctl is-active kafka.service
if [ $? -eq 0 ]; then
echo "kafka 安装成功"
else
echo "kafka 安装失败"
exit 1
fi
}
read -p "请输入zookeeper node编号（默认为1）： " ZKID
if [ -z "$ZKID" ]; then
ZKID=1
elif [[ ! "$ZKID" =~ ^[0-9]+$ ]]; then
echo "请输入正确的zookeeper node编号" 1
exit
else
true
fi
install_jdk
install_zookeeper
install_kafka
标签：bin,jdk,zookeeper,echo,usr,kafka,local 来源： https://www.cnblogs.com/joecy/p/16465205.html
本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享； 2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关； 3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关； 4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除； 5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。