栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

linux 单机安装 kafka

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

linux 单机安装 kafka

linux 单机安装 kafka,个人练习的时候是非常方便的

安装 kafka 前需要先安装 java 的环境,这里对 java 的版本和 kafka 的版本有要求。kafka 使用Scala 语言开发,因此在下载 kafka 时,需要看其使用的 Scala 的版本及对应的 java 版本是否一致,避免出现版本问题

笔者这里使用的 java 版本是 java8,因此使用 kafka 的版本是 kafka_2.12-2.8.1.tgz,Scala 的版本和 kafka 的版本可以在 kafa 官网看到

目录

1、官网下载 kafka

2、安装 kafka

3、启动 kafka

4、测试


1、官网下载 kafka

https://kafka.apache.org/kafka官网:

选择适合已安装 java 环境的 kafka 版本

笔者是 java8 的环境,选择的 kafka 的版本是 kafka_2.12-2.8.1.tgz

2、安装 kafka

将下载的 kafka 安装包上传到 linux

 创建 kafka 安装目录

mkdir /usr/local/kafka

 将 kafka 安装包解压到新创建的 kafka 目录

tar -xzf kafka_2.12-2.8.1.tgz -C /usr/local/kafka

 进入 kafka 安装目录

cd /usr/local/kafka/kafka_2.12-2.8.1/

 进入 config 目录,编辑 server.properties 文件

cd config

编辑  server.properties 文件

 vi server.properties

将 listeners 和 advertised.listeners 地址修改为当前机器 ip 地址(笔者当前机器 ip 地址是192.168.0.124),端口默认9092

然后修改 zookeeper 地址,笔者这里 zookeeper 的地址是 192.168.0.111:2181,读者可根据自己的情况修改

server.properties 文件编辑完成后,开放放火墙端口 9092

查看防火墙所有开放的端口:

firewall-cmd --list-port

开放防火墙端口 9092

firewall-cmd --zone=public --add-port=9092/tcp --permanent

更新防火墙规则(无需断开连接,动态添加规则)

firewall-cmd --reload

 

3、启动 kafka

启动 kafka 前需要先启动 zookeeper

没安装 zookeeper 的朋友可以先看这2篇文章

windows 环境 安装 zookeeper:https://blog.csdn.net/wsjzzcbq/article/details/88301892 

linux 环境 安装 zookeeper:https://blog.csdn.net/wsjzzcbq/article/details/88310571

zookeeper 启动成功后,启动 kafka

启动 kafka 命令

bin/kafka-server-start.sh config/server.properties &

 停止 kafka

bin/kafka-server-stop.sh

4、测试

启动 kafka 后,打开2个终端连接 linux,然后分别进入 kafka 安装目录 

cd /usr/local/kafka/kafka_2.12-2.8.1/

 开启消费者监听消息

bin/kafka-console-consumer.sh --bootstrap-server 192.168.0.124:9092 --topic demo-topic --from-beginning

打开生产者发送消息

bin/kafka-console-producer.sh --broker-list 192.168.0.124:9092 --topic demo-topic

效果图

至此完

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/998840.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号