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

Mac下Kafka的简单使用

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

Mac下Kafka的简单使用

环境:Kafka3.0.0
首先进入到本机安装Kafka的bin目录下
cd /usr/local/Cellar/kafka/3.0.0/bin

1.启动ZooKeeper

./zookeeper-server-start /usr/local/etc/kafka/zookeeper.properties &

2.启动Kafka

./kafka-server-start /usr/local/etc/kafka/server.properties &

3.创建一个topic,名称为test

kafka-topics --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic  test

4.查看所有topic

kafka-topics --list -bootstrap-server localhost:9092

5.新建一个终端窗口,向test中发送消息

 kafka-console-producer --broker-list localhost:9092 --topic test

6.新建一个终端窗口,向test接收消息

kafka-console-consumer --bootstrap-server localhost:9092 --topic test --from-beginning

7.停止kafka服务

./kafka-server-stop

8.停止zookeeper服务

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

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

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