一、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 ----停止
注:以上内容仅提供参考和交流,请勿用于商业用途,如有侵权联系本人删除!
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。