1.环境搭建1.1搭建Kafka集群1.将Kafka的安装包上传到虚拟机，并解压cd/export/software/tar-xvzfkafka_2.12-2.4.1.tgz-C../server/cd/export/server/kafka_2.12-2.4.1/2.修改server.propertiescd/export/server/kafka_2.12-2.4.1/configvimserver.properties#指定broker的idbroker.id=0#指定kafka的绑定监听的地址listeners=PLAINTEXT://node1.itcast.cn:9092#指定Kafka数据的位置log.dirs=/export/server/kafka_2.12-2.4.1/data#配置zk的三个节点zookeeper.connect=node1.itcast.cn:2181,node2.itcast.cn:2181,node3.itcast.cn:21813.将安装好的kafka复制到另外两台服务器cd/export/serverscp-rkafka_2.12-2.4.1/node2.itcast.cn:$PWDscp-rkafka_2.12-2.4.1/node3.itcast.cn:$PWD修改另外两个节点的broker.id分别为1和2---------node2.itcast.cn--------------cd/export/server/kafka_2.12-2.4.1/configvimerver.propertiesbroker.id=1listeners=PLAINTEXT://node2.itcast.cn:9092--------node3.itcast.cn--------------cd/export/server/kafka_2.12-2.4.1/configvimserver.propertiesbroker.id=2listeners=PLAINTEXT://node3.itcast.cn:90924.配置KAFKA_HOME环境变量vim/etc/profileexportKAFKA_HOME=/export/server/kafka_2.12-2.4.1exportPATH=:$PATH:${KAFKA_HOME}分发到各个节点scp/etc/profilenode2.itcast.cn:$PWDscp/etc/profilenode3.itcast.cn:$PWD每个节点加载环境变量source/etc/profile5.启动服务器#启动ZooKeepernohupbin/zookeeper-server-start.shconfig/zookeeper.properties&#启动Kafkacd/export/server/kafka_2.12-2.4.1nohupbin/kafka-server-start.shconfig/server.properties2>&1&#测试Kafka集群是否启动成功:使用jps查看各个节点是否出现有kafka或者通过zookeeper查看brokers节点目录下,是否有三个ids1.2目录结构分析目录名称说明binKafka的所有执行脚本都在这里。例如：启动Kafka服务器、创建Topic、生产者、消费者程序等等configKafka的所有配置文件libs运行Kafka所需要的所有JAR包logsKafka的所有日志文件，如果Kafka出现一些问题，需要到该目录中去查看异常信息site-docsKafka的网站帮助文件1.3Kafka一键启动/关闭脚本为了方便将来进行一键启动、关闭Kafka，我们可以编写一个shell脚本来操作。将来只要执行一次该脚本就可以快速启动/关闭Kafka。1.在节点1中创建/export/onekey目录cd/export/onekey2.准备slave配置文件，用于保存要启动哪几个节点上的kafkanode1.itcast.cnnode2.itcast.cnnode3.itcast.cn3.编写start-kafka.sh脚本vimstart-kafka.shcat/export/onekey/slave|whilereadlinedo{echo$linessh$line"source/etc/profile;exportJMX_PORT=9988;nohup${KAFKA_HOME}/bin/kafka-server-start.sh${KAFKA_HOME}/config/server.properties>/dev/nul*2>&1&"}&waitdone4.编写stop-kafka.sh脚本vimstop-kafka.shcat/export/onekey/slave|whilereadlinedo{echo$linessh$line"source/etc/profile;jps|grepKafka|cut-d''-f1|xargskill-s9"}&waitdone5.给start-kafka.sh、stop-kafka.sh配置执行权限chmodu+xstart-kafka.shchmodu+xstop-kafka.sh6.执行一键启动、一键关闭./start-kafka.sh./stop-kafka.sh
