kafka window环境下使用（内置zookeeper）
2024-08-31 12:21:17
下载
- kafka 官网下载最新版本（已集成 zookeeper）
- 解压到 D 盘的 kafka_2.12-2.3.0
运行 zookeeper
执行 zookeeper 运行命令
D:\kafka_2.12-2.3.0\bin\windows\zookeeper-server-start.bat D:\kafka_2.12-2.3.0\config\zookeeper.properties
执行结果
默认端口号是
2181
运行 kafka
打开新的命令行，执行：
D:\kafka_2.12-2.3.0\bin\windows\kafka-server-start.bat D:\kafka_2.12-2.3.0\config\server.properties
执行结果：
创建主题
创建一个名为
topic_test的主题，包含一个分区，只有一个副本D:\kafka_2.12-2.3.0\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic topic_test
生产消息
D:\kafka_2.12-2.3.0\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic topic_test
消费消息
D:\kafka_2.12-2.3.0\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic topic_test --from-beginning
最新文章
- MVC如何使用开源分页插件shenniu.pager.js
- Waud.js – 使用HTML5降级处理的Web音频库
- bzoj1023: [SHOI2008]cactus仙人掌图
- 【noiOJ】p8210
- js正则表达式校验非负整数：^\d+$ 或 ^[1-9]\d*|0$ 【转载】
- 学习调用WCF服务的各种方法
- ContentType Office
- onmousemove和onmouseout事件的调用，和js使用双引号、单引号的时候应该注意的问题
- 定时器Timer
- poj1459
- DFS Zoj 2110
- Android学习手记(6) TabActivity和TabHost
- EAT/IAT Hook
- 2015第23周四HTML特殊字符显示问题
- Hibernate(三)——框架中的关系映射
- ASP.NET MVC：会导致锁定的会话
- RSA签名和验证数据
- IE兼容事件绑定V1.0
- 如何指定一个计划和目标——6W
- MVC+三层+ASP.NET简单登录验证