kafka的简单命令
2024-10-07 20:36:17
启动kafka自带的zookeeper
./bin/zookeeper-server-start.sh config/zookeeper.properties &
启动kafka
./bin/kafka-server-start.sh config/server.properties
创建一个叫做“test”的topic,它只有一个分区,一个副本。
./bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
查看创建的topic
./bin/kafka-topics.sh --list --zookeeper localhost:2181
发送消息
./bin/kafka-console-producer.sh --broker-list 192.168.137.128:9092 --topic test
接受消息
./bin/kafka-console-consumer.sh --bootstrap-server 192.168.137.128:9092 --topic test --from-beginning
{"id":"b18a865a-fe8d-465d-bc67-865e51e348cd","msg":"zhangxianlong,mawanqiu","sendTime":"2018-09-25 09:57:51"}
最新文章
- mysql延迟查询, 覆盖索引使用例子
- iOS10 权限配置
- Git分支(本地)
- JavaScript类型转换
- 用 OneAPM Cloud Insight 监控 Docker 性能
- C++中Const说明
- 浅谈 Python 程序和 C 程序的整合
- cloudeye的实现
- svg学习之旅(1)
- CNN 卷积层输入Map大小计算
- 【开源项目】智能电视及电视盒子的控制应用TVRemoteIME的接口说明
- convert 函数的使用
- ubuntu上mongodb的安装
- Class:Task 类
- HDU - 4198 Quick out of the Harbour (BFS+优先队列)
- redis关闭/重启服务器
- Ognl_JSTL_学习笔记
- Mina 系列(二)之基础
- 优化png图片的历程
- cpu的用户态和内核态和内存的用户空间内核空间