记录一下linux-kafka命令
使用工具：puTTY 下载地址：Download PuTTY - a free SSH and telnet client for Windows
login as: root
root@*******'s password:
Last login: Fri Apr 28 14:54:26 2023 from 10.10.16.80
[root@kafka272c41 ~]# cd ..
[root@kafka272c41 /]# ls -a
. .. .autorelabel bin boot config dev etc home kafka lib lib64 media mnt opt proc root run sangfor sbin srv sys tmp usr var
[root@kafka272c41 /]# cd kafka
[root@kafka272c41 kafka]# ls -a
. .. flink-1.13.6 kafka_2.13-2.7.2 kafka-run.log lib_conn logs logs_ nifi-1.16.3 node-v16.13.2-linux-x64 streamx-console-service-1.2.3 tools zookeeper zookeeper-run.log
[root@kafka272c41 kafka]# cd kafka_2.13-2.7.2
[root@kafka272c41 kafka_2.13-2.7.2]# ls -a
. .. bin config libs LICENSE licenses logs logs_ NOTICE site-docs test
/*查看topic列表*/
[root@kafka272c41 kafka_2.13-2.7.2]# bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 --list
NXLSCconver
NXLSConver
...
[root@kafka272c41 kafka_2.13-2.7.2]#
/*查看具体topic信息*/
[root@kafka272c41 kafka_2.13-2.7.2]# bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic ****
Topic: **** PartitionCount: 30 ReplicationFactor: 1 Configs:
Topic: **** Partition: 0 Leader: 0 Replicas: 0 Isr: 0
Topic: **** Partition: 1 Leader: 0 Replicas: 0 Isr: 0
Topic: **** Partition: 2 Leader: 0 Replicas: 0 Isr: 0
...
/*删除指定topic*/
bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 --delete --topic ****
/*新建topic*/
bin/kafka-topics --zookeeper 127.0.0.1:2181 --create --topic **** --partitions 30 --replication-factor 1