1、Kafka主题（Topic/文件夹）

注意：下方涉及topic的所有操作都是在kafka安装目录的bin文件夹下执行

/usr/local/kafka_2.13-3.7.0/bin

2、Kafka主题（Topic/文件夹）的一些操作

2.1、创建主题（Topic/文件夹）

./kafka-topics.sh --create --topic helloword --bootstrap-server localhost:9092

2.2、列出所有主题（Topic/文件夹）

./kafka-topics.sh --list  --bootstrap-server localhost:9092

2.3、删除主题（Topic/文件夹）

./kafka-topics.sh --list  --bootstrap-server localhost:9092

2.4、显示主题（Topic/文件夹）详细信息

./kafka-topics.sh --describe --topic helloword --bootstrap-server localhost:9092

2.5、修改主题（Topic/文件夹）分区数

./kafka-topics.sh --alter --topic helloword --partitions 5 --bootstrap-server localhost:9092

修改后的分区数是5

3、生产者：在Kafka主题（Topic/文件夹）中写事件的操作（./kafka-console-producer.sh）

3.1、查看如何使用写入事件的脚本

执行./kafka-console-producer.sh脚本可以查看如何往topic里边写入事件

./kafka-console-producer.sh

3.2、往主题中写入事件

执行如下命令可以往指定主题中写入事件：

• 每次换行写入一个新的主题
• 按ctrl+c结束

./kafka-console-producer.sh --topic helloword --bootstrap-server localhost:9092

4、消费者：从Kafka主题（Topic/文件夹）中读事件的操作（./kafka-console-consumer.sh）

4.1、不带任何参数执行脚本会告诉如何使用

./kafka-console-consumer.sh

4.2、从kafka指定topic中读取事件

注意：

• 带上 –from-beginning 参数是从第一条读取事件；
• 不带 –from-beginning 参数只能读取消费者启动后生产者发送的数据

./kafka-console-consumer.sh --topic helloword --from-beginning --bootstrap-server localhost:9092