kafka基本命令查看博客《kafka2.5.0基本命令》
本博文所使用kafka版本2.5.0，操作系统centos8.
1）创建主题
创建my-topic主题，该主题有 1 个副本，8个分区：
$ bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 8 --topic my-topic Created topic my-topic.
2）列出主题
$ bin/kafka-topics.sh --list --bootstrap-server localhost:9092
my-topic
test
3) 更改主题分区个数：
注意：分区个数只能改多，不能改少，这里从8个分区改为16个：
$ bin/kafka-topics.sh --bootstrap-server localhost:9092 --alter --topic my-topic --partitions 16 artitions 16
验证分区扩建，cd 到kafka默认日志数据目录下： /tmp/kafka-logs，可以查看到16个分区文件夹：
drwxrwxr-x. 2 joyce joyce 141 Jun 21 05:17 my-topic-0 drwxrwxr-x. 2 joyce joyce 141 Jun 21 05:17 my-topic-1 drwxrwxr-x. 2 joyce joyce 141 Jun 21 05:17 my-topic-2 drwxrwxr-x. 2 joyce joyce 141 Jun 21 05:17 my-topic-3
.......
每个分区文件夹的核心文件是.log文件：
[joyce@192 kafka-logs]$ cd my-topic-0 [joyce@192 my-topic-0]$ ll total 4 -rw-rw-r--. 1 joyce joyce 10485760 Jun 21 05:17 00000000000000000000.index -rw-rw-r--. 1 joyce joyce 0 Jun 21 05:17 00000000000000000000.log // 0就代表便宜量，20个0代表可以存储4亿亿的数据！ -rw-rw-r--. 1 joyce joyce 10485756 Jun 21 05:17 00000000000000000000.timeindex -rw-rw-r--. 1 joyce joyce 8 Jun 21 05:17 leader-epoch-checkpoint
查看分区当前情况：
[joyce@192 kafka_2.12-2.5.0]$ bin/kafka-topics.sh --bootstrap-server localhost:9092 --describe Topic: kafka-boot PartitionCount: 1 ReplicationFactor: 1 Configs: segment.bytes=1073741824 Topic: kafka-boot Partition: 0 Leader: 0 Replicas: 0 Isr: 0 Topic: my-topic PartitionCount: 16 ReplicationFactor: 1 Configs: segment.bytes=1073741824 Topic: my-topic Partition: 0 Leader: 0 Replicas: 0 Isr: 0 Topic: my-topic Partition: 1 Leader: 0 Replicas: 0 Isr: 0 Topic: my-topic Partition: 2 Leader: 0 Replicas: 0 Isr: 0 Topic: my-topic Partition: 3 Leader: 0 Replicas: 0 Isr: 0
......
4）删除分区
$ bin/kafka-topics.sh --bootstrap-server localhost:9092 --delete --topic __consumer_offsets
5）生产者
需连接多个broker的话，中间用逗号分隔：
$ bin/kafka-console-producer.sh --bootstrap-server localhost:9092,192.168.2.60:9092 --topic my-topic
6）消费者
消费者消费消息：
$ bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic my-topic --from-beginning
end.
原文：https://www.cnblogs.com/zhuwenjoyce/p/13173218.html