目录

一、主题topic命令行操作

1.查看操作主题的命令参数

2.连接kafka地址，创建名为kaf的主题，指定分区和副本数量

3.查看所有主题的名称

4.查看主题的详细信息

5.修改主题（修改分区数）

二、生产者命令行操作

1.查看操作生产者的命令参数：kafka-console-produce.sh

2.生产一个数据，放到topic kaf中

3.消费者使用数据 slave2 slave3都可

---

一、主题topic命令行操作

1.查看操作主题的命令参数：kafka-topic.sh

参数	说明
--bootstrap-server<String: server to connect to>	设置连接kafka的主机名和端口号
--topic <String: topic>	设置操作主题的名称
--create	创建主题
--delete	删除主题
--alter	修改主题（修改主题的分区数）
--list	显示所有主题
--describe	显示指定主题的详细信息
--partitions <Integer: # of partitions>	设置主题的分区数
partitions <Integer: # of partitions>	设置分区的副本数量

2.连接kafka地址，创建名为kaf的主题，指定分区和副本数量：--bootstrap-server slave2:9092

3.查看所有主题的名称

 

4.查看主题的详细信息

5.修改主题（修改分区数），只能改更大的，分区数只能增加

二、生产者命令行操作

1.查看操作生产者的命令参数：kafka-console-produce.sh

2.生产一个数据，放到topic kaf中，

3.消费者使用数据 slave2 slave3都可

 

 

 slave1生产什么slave3消费什么

 

 

 但是消费者进入前的数据并没有拉取到，应该怎么样才可以把之前的数据拉取到

 在slave3中使用该命令即可