Linux下 Apache Kafka 安装与配置

一、linux版本：lsb_release -a

二、官网地址：http://kafka.apache.org/downloads

我们选择稳定版：2.8

三、安装ZooKeeper

当前下载的kafka程序里自带Zookeeper，可以直接使用其自带的Zookeeper；也可以自己安装 ZooKeeper，不会的话可以看我另一边文章：https://blog.csdn.net/wang_jing_jing/article/details/118697915

四、安装Kafka

4.1、下载二进制压缩包：

wget https://mirrors.bfsu.edu.cn/apache/kafka/2.8.0/kafka_2.13-2.8.0.tgz

4.2、解压缩：tar -zxvf kafka_2.13-2.8.0.tgz

4.3、移动至local下：mv kafka_2.13-2.8.0 /usr/local/kafka

4.4、添加至环境变量：

4.4.1、vim /etc/profile

4.4.2、echo export PATH=\"\$PATH:/usr/local/kafka/bin\" >> ~/.bashrc

4.4.3、source ~/.bashrc

五、KafKa配置与启动

5.1、进入配置文件：vim /usr/local/kafka/config/server.properties

5.2、broker.id是kafka broker的编号，集群里每个broker的id需不同。默认是0

5.3、listeners是监听地址，需要提供外网服务的话，要设置本地的IP地址

5.4、log.dirs是日志目录，需要设置

5.5、设置Zookeeper集群地址，我是在同一个服务器上搭建了kafka和Zookeeper，所以填的本地地址

5.6、启动：kafka-server-start.sh -daemon /usr/local/kafka/config/server.properties

-daemon 参数会将任务转入后台运行，输出日志信息将写入日志文件，日志文件在执行命令的目录下的logs目录中kafkaServer.out。

5.6、查看日志：tail -n100 -f /usr/local/kafka/logs/server.log（结尾输同started说明启动成功。）

六、kafka 常用命令

6.1：kafka-server-start.sh -daemon /usr/local/kafka/config/server.properties       ----启动

6.2：kafka-server-stop.sh       ----停止

注：以上内容仅提供参考和交流，请勿用于商业用途，如有侵权联系本人删除！