目录
一、主题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中使用该命令即可