一、主题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中使用该命令即可
本文转载自: https://blog.csdn.net/m0_58046550/article/details/127950202
版权归原作者 lidan0427 所有， 如有侵权，请联系我们删除。
版权归原作者 lidan0427 所有， 如有侵权，请联系我们删除。