论坛
潜水/灌水快乐,沉淀知识,认识更多同行。
ToB圈子
加入IT圈,遇到更多同好之人。
朋友圈
看朋友圈动态,了解ToB世界。
ToB门户
了解全球最新的ToB事件
博客
Blog
排行榜
Ranklist
文库
业界最专业的IT文库,上传资料也可以赚钱
下载
分享
Share
导读
Guide
相册
Album
记录
Doing
搜索
本版
文章
帖子
ToB圈子
用户
免费入驻
产品入驻
解决方案入驻
公司入驻
案例入驻
登录
·
注册
只需一步,快速开始
账号登录
立即注册
找回密码
用户名
Email
自动登录
找回密码
密码
登录
立即注册
首页
找靠谱产品
找解决方案
找靠谱公司
找案例
找对的人
专家智库
悬赏任务
圈子
SAAS
IT评测·应用市场-qidao123.com
»
论坛
›
物联网
›
物联网
›
centos7安装单机kafka
centos7安装单机kafka
半亩花草
金牌会员
|
2025-3-23 23:20:01
|
显示全部楼层
|
阅读模式
楼主
主题
968
|
帖子
968
|
积分
2904
下载安装包并进行解压:kafka_2.12-2.2.1.tgz
#解压
tar -zxvf /usr/local/kafka/kafka_2.12-2.2.1.tgz
复制代码
consumer.properties 是消耗者的相干设置
producer.properties 是生产者的相干设置
server.properties 是 kafka 服务的设置
zookeeper.properties 是 zookeeper 的相干设置
zookeeper 中记录kafka的broker等信息
#修改服务配置:server.properties
vi /usr/local/kafka/kafka_2.12-2.2.1/config/server.properties
复制代码
# 唯一标识,集群里每个broker的id需不同
broker.id=0
#定义 Kafka Broker 实际监听的地址和端口
listeners=PLAINTEXT://192.168.159.100:9092
#定义客户端连接 Broker 的地址
advertised.listeners=PLAINTEXT://192.168.159.100:9092
# 日志路径,路径需提前创建好,且必须有读写权限
log.dirs=/tmp/kafka-logs
#设置zk的连接地址及端口。申明kafka所连接的zookeeper的地址 ,需配置为zookeeper的地址。
zookeeper.connect=192.168.159.100:2181
复制代码
启动kafka:
#进入目录
cd /usr/local/kafka/kafka_2.12-2.2.1
#启动
./bin/kafka-server-start.sh -daemon config/server.properties
复制代码
验证kafka是否启动成功
#查看java进程
jps
#输出:
43267 QuorumPeerMain
45498 Kafka
63343 Jps
复制代码
kafka-topics.sh创建topic:
./bin/kafka-topics.sh --bootstrap-server 192.168.159.100:9092 --create --topic testTopic --partitions 1 --replication-factor 1
# --bootstrap-server 表示要连接到哪台机器上
# --create 表示要创建一个 topic
# --topic 表示要创建的topic的名称,这里是 testTopic
# --partitions 表示分区数
# --replication-factor 表示副本数,不能大于 kafka 的节点数
复制代码
kafka-console-consumer.sh 利用 consumer 控制台订阅 topic
./bin/kafka-console-consumer.sh --bootstrap-server 192.168.159.100:9092 --topic testTopic --from-beginning
# --from-beginning 消费者订阅topic之前,生产者如果已经发布了一个event,这时消费者是拿不到这个event的,如果想要拿到之前已经发布的event,就加上该参数。
复制代码
kafka-console-producer.sh 利用 producer 控制台发布 event
./bin/kafka-console-producer.sh --broker-list 192.168.159.100:9092 --topic testTopic
# 在箭头后输入要发送的 event,每行代表一个 event
复制代码
测试:
生产者发送消息:
消耗者收到消息:
免责声明:如果侵犯了您的权益,请联系站长,我们会及时删除侵权内容,谢谢合作!更多信息从访问主页:qidao123.com:ToB企服之家,中国第一个企服评测及商务社交产业平台。
本帖子中包含更多资源
您需要
登录
才可以下载或查看,没有账号?
立即注册
x
回复
使用道具
举报
0 个回复
倒序浏览
返回列表
快速回复
高级模式
B
Color
Image
Link
Quote
Code
Smilies
您需要登录后才可以回帖
登录
or
立即注册
本版积分规则
发表回复
回帖并转播
回帖后跳转到最后一页
发新帖
回复
半亩花草
金牌会员
这个人很懒什么都没写!
楼主热帖
YOLOV5 代码复现以及搭载服务器运行 ...
本周涨粉一倍,我决定再开源一个商超管 ...
APP性能优化
Java集合框架(五)-Collections 和 泛型 ...
安装Python
经典Python题目:一个列表或者数组去重 ...
Spring5——JdbcTemplate笔记
《C++性能优化指南》 linux版代码及原 ...
C++初探索
go-zero插件goctl-swagger的坑
标签云
运维
CIO
存储
服务器
快速回复
返回顶部
返回列表