一、kafka-topics.sh
1.参数
| 参数 | 描述 |
|---|---|
| –bootstrap-server | 连接的Kafka Broker主机名称和端口号 |
| –topic | 操作的topic名称 |
| –create | 创建主题 |
| –delete | 删除主题 |
| –alter | 修改主题 |
| –list | 查看所有主题 |
| –describe | 查看主题详细描述 |
| –partition | 设置分区数 |
| –replication-factor | 设置分区副本 |
| –config | 更新系统默认的配置 |
2.实例
- 查看当前服务器中的所有topic
bin/kafka-topics.sh \
--bootstrap-server node1:9092 \
--list
- 创建first topic
bin/kafka-topics.sh \
--bootstrap-server node1:9092 \
--create \
--partitions 1 \
--replication-factor 2 \
--topic first
- 查看first主题的详细信息
bin/kafka-topics.sh \
--bootstrap-server node1:9092 \
--describe \
--topic first
- 修改分区数（注意：分区只能增加，不能减少）
bin/kafka-topics.sh \
--bootstrap-server node1:9092 \
--alter \
--topic first \
--partitions 3
- 删除topic
bin/kafka-topics.sh \
--bootstrap-server node1:9092 \
--delete \
--topic first
二、kafka-console-producer.sh
1.参数
| 参数 | 描述 |
|---|---|
| –bootstrap-server | 连接的Kafka Broker主机名称和端口号 |
| –topic | 操作的topic名称 |
2.实例
- 发送消息
bin/kafka-console-producer.sh \
--bootstrap-server node1:9092 \
--topic first
三、kafka-console-consumer.sh
1.参数
|参数|描述|
|–bootstrap-server|连接的Kafka Broker主机名称和端口号|
|–topic|操作的topic名称|
|–from-beginning|从头开始消费|
|–group|指定消费者组名称|
2.实例
- 消费first主题中的数据
bin/kafka-console-consumer.sh \
--bootstrap-server node1:9092 \
--topic first
- 把主题中所有的数据都读取出来（包括历史数据）
bin/kafka-console-consumer.sh \
--bootstrap-server node1:9092 \
--from-beginning \
--topic first
版权声明：本文为feizuiku0116原创文章，遵循CC 4.0 BY-SA版权协议，转载请附上原文出处链接和本声明。