kafka shell
2024-09-04 03:15:26
停止
./bin/kafka-server-stop.sh
启动
nohup sh kafka-server-start.sh ../config/server.properties &
创建topic ，并指定partion
sh kafka-topics.sh --create --zookeeper 192.168.67.74:2182,192.168.67.68:2182,192.168.67.73:2182/kafka08 --replication-factor 3 --partitions 9 --topic DS.crawl_news_download_queue_v2_6
查看kafka 一个groupid 消费的偏移量
sh
kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zookeeper192.168.67.74:2182,192.168.67.68:2182,192.168.67.73:2182/kafka08 --group parse_group
跟读
sh kafka-console-consumer.sh --zookeeper 192.168.67.35:2182,192.168.67.36:2182,192.168.67.37:2182/kafka08 --topic DS.crawl.output.mf.self
查看某个topic的partion情况
sh kafka-topics.sh --describe --zookeeper 192.168.67.35:2182,192.168.67.36:2182,192.168.67.37:2182/kafka08 --topic DS.crawl.output.mf.self
增加topic的partition
./kafka-topics.sh --alter --topic topic1 --zookeeper zkip:2181/kafka --partitions 6
删除topic
sh kafka-topics.sh --delete --zookeeper 192.168.67.74:2182,192.168.67.68:2182,192.168.67.73:2182/kafka08 --topic DS.crawl_parseToTopic_v2_metasearch
写
sh kafka-console-producer.sh --broker-list 192.168.67.35:8791,192.168.67.36:8791,192.168.67.37:8791 --topic test、
跟读
sh kafka-console-consumer.sh --zookeeper 192.168.67.35:2182,192.168.67.36:2182,192.168.67.37:2182/kafka08
最新文章
- Local Desktop
- Spring-data-jpa详解，全方位介绍。
- 隐藏nginx 版本号信息
- 安卓第九天笔记-Activity
- jQuery Ajax学习
- xamarin.ios 豆瓣电台视频教程
- [转载]easyui datagrid 时间格化（JS 日期时间本地化显示）
- input里面的查找标记 ő
- [PWA] 4. Hijacking Request
- Lucene.Net 2.3.1开发介绍 —— 二、分词（三）
- BZOJ 1367([Baltic2004]sequence-左偏树+中位数贪心)
- service structure flowchart [mobile to server via HTTP RESTful API and TCP/IP in a map]
- Qt中的坐标系统
- static 关键字的作用
- Eclipse中启动Tomcat报错：[There is insufficient memory for the Java Runtime Environment to continue.]的解决方案
- Open SuSE虚拟机分辨率不能自适应的解决办法
- P4702 取石子
- CentOS7 搭建影梭服务器
- brew安装和换源
- Android Service用法知识点的讲解