一、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。