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

5. kafka单机版本

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

5. kafka单机版本

1.上传kafka的压缩包至: /opt目录下

2. 解压kafka至:/usr/local,目录下
tar -zxvf kafka_2.11-2.4.1.tgz -C /usr/local
3. 为了方便操作,重命名:
mv kafka_2.11-2.4.1/ kafka-2.4.1
4. 配置环境变量:
(1)vim /etc/profile
添加配置项:export KAFKA_HOME=/usr/local/kafka-2.4.1

5. 可以选择使用kafka内置的zk,也可以使用自己安装的zk,
需要修改zk的配置,以及kafka的配置

6. 启动zk的客户端:
(1)在kafka的bin目录下,有zk的客户端,bin目录下启动
[root@bogon bin]# ./zookeeper-shell.sh localhost:2181

这些节点存放的都是zk集群的元数据信息。
brokers中:[ids,seqid,topics]



7. 建立完topic后,生产者发送消息:
(1)用控制台的方式创建消息:

8. 消费消息:

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

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

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