#!/bin/bash kafka_ver=kafka_2.11-0.11.0.1 kafka_tgz=$kafka_ver.tgz hostip=`hostname -i` broker_id=`echo $hostip | awk -F . ‘{print $4}‘` cd /home/service/app wget http://10.12.29.98:8090/tools/kafka/$kafka_tgz tar zxf $kafka_tgz mv $kafka_ver kafka cd kafka/bin mv kafka-server-start.sh kafka-server-start.sh.bak wget http://10.12.29.98:8090/tools/kafka/kafka-server-start.sh cd ../config mv log4j.properties log4j.properties.bak #mv server.properties server.properties.bak wget http://10.12.29.98:8090/tools/kafka/log4j.properties #wget http://10.12.29.98:8090/tools/kafka/server.properties cat <<EOF > server.properties broker.id=$broker_id listeners=PLAINTEXT://$hostip:9092 port=9092 host.name=$hostip socket.receive.buffer.bytes=102400 socket.request.max.bytes=104857600 log.dirs=/home/service/var/kafka num.partitions=6 offsets.topic.replication.factor=2 log.retention.hours=72 log.retention.bytes=1073741824 log.segment.bytes=1073741824 log.retention.check.interval.ms=100000 zookeeper.connect=10.32.212.18:2181,10.32.196.38:2181,10.32.214.17:2181/saleskafka-gzqy zookeeper.connection.timeout.ms=6000 group.initial.rebalance.delay.ms=3000 log.cleaner.enable=true delete.topic.enable=true EOF mkdir -p /home/service/var/kafka chown -R service.service /home/service/var/kafka chown -R service.service /home/service/app/kafka
原文:https://www.cnblogs.com/lwhctv/p/11257124.html