Kafka 必须依赖 ZooKeeper，所以应该确保 ZooKeeper 已成功运行。Kafka 内置了 ZooKeeper，故如果未安装 ZooKeeper可以使用其内置ZooKeeper。但我们一般使用外部 zookeeper 服务。 下载地址：http://kafka.apache.org/downloads 其中kafka_2.11-2.4.0表示 Kafka 版本 2.4.0，Scala 版本 2.11。 1. 上传及解压 ```shell [root@hadoop101 software]# tar -zxf kafka_2.11-0.11.0.2.gz -C /opt/install/ ``` 2. 创建软连接和环境变量[可选] ```shell [root@hadoop101 install]# ln -s kafka_2.11-0.11.0.2 kafka ``` 3. 将kakfa添加到环境变量中 ```shell [root@hadoop101 install]# vim /etc/profile export KAFKA_HOME=/opt/install/kafka export PATH=$KAFKA_HOME/bin:$PATH -- 让更改生效 [root@hadoop101 install]# source /etc/profile ``` 4. 修改{kafka_home}/config/server.properties ```properties [root@hadoop101 config]# vim server.properties # 要删除topic是否真正删除, 默认为false, 只是标记删除,并没有真正删除, 实际开发环境中使用false delete.topic.enable=true # 设置日志[数据]的存储位置, 默认是/tmp目录下, 容易丢失 log.dirs=/opt/install/kafka/logs # 使用我们自己安装的zookeeper # hadoop101:2181 对应自己机器的主机名:端口 zookeeper.connect=hadoop101:2181 # kafka服务器地址 listeners=PLAINTEXT://hadoop101:9092 ``` 5. 启动kafka ```shell -- 如果把server.properties换成zookeeper.properties则是启用kafka内置的zookeeper -- 启动Kafka前记得先启动Zookeeper -- 启动方式1：后台运行 [root@hadoop101 kafka]# bin/kafka-server-start.sh config/server.properties -- 启动方式2：守护进程启动 [root@hadoop101 kafka]# bin/kafka-server-start.sh -daemon config/server.properties [root@hadoop101 kafka]# jps 3555 Kafka 3622 Jps -- 关闭kafka的命令 [root@hadoop101 kafka]# bin/kafka-server-stop.sh ```