kafka2.5.0 主题Topic

Posted 2020-12-11 zhuwenjoyce

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:24 my-topic-10
drwxrwxr-x. 2 joyce joyce  141 Jun 21 05:24 my-topic-11
drwxrwxr-x. 2 joyce joyce  141 Jun 21 05:24 my-topic-12
drwxrwxr-x. 2 joyce joyce  141 Jun 21 05:24 my-topic-13
drwxrwxr-x. 2 joyce joyce  141 Jun 21 05:24 my-topic-14
drwxrwxr-x. 2 joyce joyce  141 Jun 21 05:24 my-topic-15
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
drwxrwxr-x. 2 joyce joyce  141 Jun 21 05:17 my-topic-4
drwxrwxr-x. 2 joyce joyce  141 Jun 21 05:17 my-topic-5
drwxrwxr-x. 2 joyce joyce  141 Jun 21 05:17 my-topic-6
drwxrwxr-x. 2 joyce joyce  141 Jun 21 05:17 my-topic-7
drwxrwxr-x. 2 joyce joyce  141 Jun 21 05:24 my-topic-8
drwxrwxr-x. 2 joyce joyce  141 Jun 21 05:24 my-topic-9

 每个分区文件夹的核心文件是.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

 

 

 

end.