部署步骤如下：
1.1 资源拷贝
1 jdk1.8
2 kafka
3 kafka-manager
1.2 jvm 配置
vim /etc/profile.d/java.sh
JAVA_HOME=/usr/local/jdk1.8.0_60
CLASS_PATH=$JAVA_HOME/lib:$JAVA_HOME/jre/lib
PATH=$JAVA_HOME/bin:$PATH
export JAVA_HOME CLASS_PATH PATH
验证 java javac java -version $JAVA_HOME
1.2 kafka 配置
zookeeper
修改 zookeeper.properties
创建 myid 文件 创建文件路经 mkdir -p /data/zookeeper
修改 service.properties
设置启动kafka 内存及jvm端口 bin/**.sh
if [ "x$KAFKA_HEAP_OPTS" = "x" ]; then
export KAFKA_HEAP_OPTS="-Xmx4G -Xms4G"
export JMX_PORT="9999"
fi
修改 日志系统级别
启动 zookeeper bin/zookeeper-server-start.sh config/zookeeper.properties
启动 kafka bin/kafka-server-start.sh config/server.properties
1.3 kafka manager
修改 kafka-manager.zkhosts="186****:2181"
修改 启动端口
1.4 zabbix kafka 端口监控
1.5 logstash 内存
kafka 命令 测试
创建 topic
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
查看 topic
bin/kafka-topics.sh --list --zookeeper localhost:2181
生产 topic
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
消费 topic
bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning
/bin/kafka-topics.sh --zookeeper localhost:2181 --alter --topic topiclog --config retention.ms=17280000
https://github.com/EamonZhang/elkstack-conf