1. 运维命令

1.1. 启动Kafka。需要在集群上每个未运行Kafka Broker Service的主机上运行以下命令：

# 在Kafka的产品目录下运行。-daemon参数是为了让进程在后台运行
[hadoop@XCloud152 kafka]$ bin/kafka-server-start.sh -daemon config/server.properties
# 查看一下进程
[hadoop@XCloud152 kafka]$ jps
788500 Kafka
...更多

1.2 查看Kafka版本

[hadoop@XCloud152 kafka]$ bin/kafka-topics.sh --version
3.1.0 (Commit:37edeed0777bacb3)

2. 主题命令

  下面kafka-topic.sh命令进入了产品的bin目录操作。
2.1 列出所有主题（topic）

[hadoop@XCloud152 bin]$ ./kafka-topics.sh --list --bootstrap-server localhost:9092
__consumer_offsets
iot_00_da
... 更多

2.2 创建主题

[hadoop@XCloud152 kafka]$ ./kafka-topics.sh --create --topic t_words --bootstrap-server localhost:9092
WARNING: Due to limitations in metric names, topics with a period ('.') or underscore ('_') could collide. To avoid issues it is best to use either, but not both.
Created topic t_words.
# 创建主题时指定分区数(10)和副本数(2)
[hadoop@XCloud152 kafka]$ ./kafka-topics.sh --create --topic st-rtc-data --bootstrap-server localhost:9092 --replication-factor 2 --partitions 10
Created topic st-rtc-data.

2.3 查看主题详情

[hadoop@XCloud152 kafka]$ ./kafka-topics.sh --describe --bootstrap-server localhost:9092 --topic st-rtc-data
Topic: st-rtc-data      TopicId: BohDQnJuQYyZP_jjjW0r8Q PartitionCount: 10      ReplicationFactor: 2      Configs: segment.bytes=1073741824
        Topic: st-rtc-data      Partition: 0    Leader: 4       Replicas: 4,1   Isr: 4,1
        Topic: st-rtc-data      Partition: 1    Leader: 1       Replicas: 1,0   Isr: 1,0
        Topic: st-rtc-data      Partition: 2    Leader: 0       Replicas: 0,2   Isr: 0
        Topic: st-rtc-data      Partition: 3    Leader: 2       Replicas: 2,4   Isr: 2,4
        Topic: st-rtc-data      Partition: 4    Leader: 4       Replicas: 4,0   Isr: 4,0
        Topic: st-rtc-data      Partition: 5    Leader: 1       Replicas: 1,2   Isr: 1,2
        Topic: st-rtc-data      Partition: 6    Leader: 0       Replicas: 0,4   Isr: 0
        Topic: st-rtc-data      Partition: 7    Leader: 2       Replicas: 2,1   Isr: 2,1
        Topic: st-rtc-data      Partition: 8    Leader: 4       Replicas: 4,2   Isr: 4,2
        Topic: st-rtc-data      Partition: 9    Leader: 1       Replicas: 1,4   Isr: 1,4

2.4. 删除主题

[hadoop@XCloud152 bin]$ ./kafka-topics.sh --delete --topic t_words --bootstrap-server localhost:9092

3. 命令行数据生产/消费

3.1 生产测试数据

[hadoop@XCloud152 bin]$ ./kafka-console-producer.sh --bootstrap-server localhost:9092 --topic words
>

回车(Enter)发送数据，Ctrl+c结束交互。
3.2 测试消费数据

./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic words --from-beginning
hello a
hello world
hello c

参考资料：《Kafka官网Quick Start》