如何使用命令查看kaf

Posted 2023-04-30

参考技术A ##查看topic分布情况 kafka-list-topic.sh
binfka-list-topic.sh --zookeeper 192.168.197.170:2181,192.168.197.171:2181 （列出所有topic的分区情况）

binfka-list-topic.sh --zookeeper 192.168.197.170:2181,192.168.197.171:2181 --topic test （查看test的分区情况）

其实kafka-list-topic.sh里面就一句

exec $(dirname $0)fka-run-class.sh kafka.admin.ListTopicCommand $@
实际是通过

kafka-run-class.sh脚本执行的包kafka.admin下面的类
##创建TOPIC kafka -create-topic.sh ，

bin/ kafka -create-topic.sh --replica 2 --partition 8 --topic test --zookeeper 192.168.197.170:2181,192.168.197.171:2181

创建名为test的topic， 8个分区分别存放数据，数据备份总共2份

bin/ kafka -create-topic.sh --replica 1 --partition 1 --topic test2 --zookeeper 192.168.197.170:2181,192.168.197.171:2181

结果 topic: test2 partition: 0 leader: 170 replicas: 170 isr: 170

##重新分配分区 kafka-reassign-partitions.sh
这个命令可以分区指定到想要的--broker-list上

binfka-reassign-partitions.sh --topics-to-move-json-file topics-to-move.json --broker-list "171" --zookeeper 192.168.197.170:2181,192.168.197.171:2181 --execute

cat topic-to-move.json

"topics":
["topic": "test2"],

"version":1


##为Topic增加 partition数目
binfka-add-partitions.sh --topic test --partition 2 --zookeeper 192.168.197.170:2181,192.168.197.171:2181 （为topic test增加2个分区）

##控制台接收消息
bin/ kafka -console-consumer.sh --zookeeper 192.168.197.170:2181,192.168.197.171:2181 --from-beginning --topic test

##控制台发送消息
binfka-console-producer.sh --broker-list 192.168.197.170:9092,192.168.197.171: 9092 --topic test

##删除topic,慎用，只会删除zookeeper中的元数据，消息文件须手动删除
binfka-run-class.sh kafka.admin.DeleteTopicCommand --topic test666 --zookeeper 192.168.197.170:2181 ,192.168.197.171:2181

##查看topic分布情况 kafka-list-topic.sh

binfka-list-topic.sh --zookeeper 192.168.197.170:2181,192.168.197.171:2181 （列出所有topic的分区情况）

binfka-list-topic.sh --zookeeper 192.168.197.170:2181,192.168.197.171:2181 --topic test （查看test的分区情况）

其实kafka-list-topic.sh里面就一句

exec $(dirname $0)fka-run-class.sh kafka.admin.ListTopicCommand $@
实际是通过

kafka-run-class.sh脚本执行的包kafka.admin下面的类
##创建TOPIC kafka -create-topic.sh ，

bin/ kafka -create-topic.sh --replica 3 --partition 8 --topic test --zookeeper 192.168.197.170:2181,192.168.197.171:2181

创建名为test的topic， 8个分区分别存放数据，数据备份总共3份

bin/ kafka -create-topic.sh --replica 1 --partition 1 --topic test2 --zookeeper 192.168.197.170:2181,192.168.197.171:2181

结果 topic: test2 partition: 0 leader: 170 replicas: 170 isr: 170

##重新分配分区 kafka-reassign-partitions.sh

这个命令可以分区指定到想要的--broker-list上

binfka-reassign-partitions.sh --topics-to-move-json-file topics-to-move.json --broker-list "171" --zookeeper 192.168.197.170:2181,192.168.197.171:2181 --execute

cat topic-to-move.json

"topics":
["topic": "test2"],

"version":1



##为Topic增加 partition数 目 kafka-add-partitions.sh

binfka-add-partitions.sh --topic test --partition 2 --zookeeper 192.168.197.170:2181,192.168.197.171:2181 （为topic test增加2个分区）

##控制台接收消息

bin/ kafka -console-consumer.sh --zookeeper 192.168.197.170:2181,192.168.197.171:2181 --from-beginning --topic test

##控制台发送消息

binfka-console-producer.sh --broker-list 192.168.197.170:9092,192.168.197.171: 9092 --topic test

##删除topic,慎用，只会删除zookeeper中的元数据，消息文件须手动删除

linux如何查看cpu型号,linux命令查看cpu使用情况

参考技术A 1."linux如何查看cpu型号，为您提供linux如何查看cpu型号图文信息，打开linux系统，在linux的桌面的空白处右击。

2.在弹出的下拉选项里，点击打开终端。

3.使用cat/proc/cpuinfo命令查询CPU的信息，其中modelname就是cpu的名称和型号。