Kafka—集群搭建完整流程

环境准备

安装jdk  安装zookeeper

搭建kafka集群

下载kafka   https://kafka.apache.org/downloads#2.2.2 解压 tar -zxvf  kafka_2.11-2.0.0.tgz 安装包发送至其他节点 添加环境变量 source生效 创建日志存放目录 修改kafka基础配置（vim server.properties）

启动kafka集群

zkServer.sh startkafka-server-start.sh $KAFKA_HOME/config/server.properties &

验证集群

 kafka-console-producer.sh --broker-list host1:9092,host2:9092,host3:9092 --topic topic_name kafka-console-consumer.sh --bootstrap-server host1:9092,host2:9092,host3:9092 --topic topic_name