内容简介:1.启停,进程状态2.topic相关3.集群相关
1.启停,进程状态
#启动。若要开启JMX端口需要加载环境变量 su hadoop ./bin/kafka-server-start.sh -daemon ./config/server.properties #停止。 su hadoop ./bin/kafka-server-stop.sh
2.topic相关
#创建topic.默认数据保留时间为7天,配置<replication-factor>至少为为2 ./bin/kafka-topics.sh --create --zookeeper $ZK_ADDR --replication-factor 2 --partitions N --topic ${topic_name} #创建topic时指定代理 ./kafka-topics.sh --zookeeper $ZK_ADDR --creat --topic --topic ${topic_name} --replica-assignment 0:1,1:2,2:3,3:4,4:0 #删除topic.不会立马删除,只会标记为删除<- marked for deletion> ./bin/kafka-topics.sh --delete --zookeeper $ZK_ADDR --topic ${topic_name} #查看topid的详细信息,只有非默认配置才会展示出来,不展示的都将是默认配置值。 ./bin/kafka-topics.sh --describe --zookeeper $ZK_ADDR --topic ${topic_name} #topic分区扩容,值能大于现有的partition的值,且这个值为增加到的值,不是增加多少的值. ./bin/kafka-topics.sh --alter --zookeeper $ZK_ADDR --topic ${topic_name} --partitions ${partition_number} #修改topic消息的保留时间.默认为7天,单位是ms. ./bin/kafka-configs.sh --alter --zookeeper $ZK_ADDR --entity-type topics --entity-name ${topic_name} --add-config retention.ms=${xxxx}
3.集群相关
#leade选举.集群自己进行再选举 ./bin/kafka-preferred-replica-election.sh --zookeeper $ZK_ADDR #leader选举.自定义leader.json文件 ./bin/kafka-preferred-replica-election.sh --zookeeper $ZK_ADDR --path-to-json-file leader.json ##leader.json文件 {"partitions":[ {"topic": "foo", "partition": 1}, {"topic": "foobar", "partition": 2} ] } #查看集群中有多少个partitons没有leader ./kafka-topics.sh --describe --zookeeper $ZK_ADDR --under-replicated-partitions
4.生产者
/export/work/kafka_9092/bin/kafka-console-producer.sh –broker-list localhost:9092 –topic ${topic_name}
/export/work/kafka_9092/bin/kafka-console-consumer.sh –bootstrap-server localhost:9092 –new-consumer –from-beginning –topic ${topic_name} | grep ${message-key-word}
5.消费者
/export/work/kafka_9092/bin/kafka-console-consumer.sh –bootstrap-server localhost:9092 –new-consumer –from-beginning –topic ${topic_name}
/export/work/kafka_9092/bin/kafka-consumer-groups.sh –list –bootstrap-server localhost:9092
/export/work/kafka_9092/bin/kafka-consumer-groups.sh –describe –bootstrap-server localhost:9092 –group ${consumer-group}
/export/work/kafka_9092/bin/kafka-consumer-groups.sh –describe –bootstrap-server localhost:9092 –group ${consumer-group}
以上就是本文的全部内容,希望本文的内容对大家的学习或者工作能带来一定的帮助,也希望大家多多支持 码农网
猜你喜欢:- Pureftpd操作指南
- 《算法互动编程》操作指南(二)
- 自底向上的web数据操作指南
- JavaScript Date(日期)操作权威指南
- 通过命令curl 操作ElasticSearch指南
- [最全操作指南] 在线六个项目全部迁移Linux
本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们。
51单片机应用从零开始
杨欣、王玉凤、刘湘黔 / 清华大学 / 2008-1 / 39.80元
《51单片机应用与实践丛书•51单片机应用从零开始》在分析初学者认知规律的基础上,结合国内重点大学一线教师的教学经验以及借鉴国外经典教材的写作手法,对51单片机的应用基础知识进行系统而翔实的介绍。读者学习每一章之后,"实例点拨"环节除了可以巩固所学的内容外,还开辟了单片机应用的视野;再加上"器件介绍"环节,又充实了对单片机从基础到应用所需要的知识。8051单片机不仅是国内用得最多的单片机之一,同时......一起来看看 《51单片机应用从零开始》 这本书的介绍吧!
JS 压缩/解压工具
在线压缩/解压 JS 代码
HEX HSV 转换工具
HEX HSV 互换工具