Kafka操作命令[速查]
2022-02-13 本文已影响0人
BarretX
本文罗列工作中常用的kafka命令，方便工作速查，并会不但更新完善。
集群状态相关命令
- 启动
kafka：
kafka-server-start.sh -daemon server.properties
- 停止
kafka：
kafka-server-stop.sh
Topic相关命令
- 创建
topic：
kafka-topics.sh --create --zookeeper 127.0.0.1:2181 --replication-factor 1 --partitions 1 --topic some_topic
- 删除
topic：
kafka-topics.sh --delete --zookeeper 127.0.0.1:2181 --topic some_topic
- 查看所有
topic：
kafka-topics.sh --list --zookeeper 127.0.0.1:2181
- 查看指定
topic：
kafka-topics.sh --list --zookeeper 127.0.0.1:2181 --topic some_topic
- 修改
topic：
kafka-topics.sh --zookeeper 127.0.0.1:2181 --alter --topic some_topic --partitions 5
生产者相关命令
- 生产消息：
kafka-console-producer.sh --broker-list 127.0.0.1:9092 --topic some_topic
消费者相关命令
- 消费消息：
kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092 --topic some_topic --group some_customer_group
- 消费组列表查询：
kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:9092 --list
- 查看某个消费组的消费详情：
kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:9092 --describe --group some_customer_group
- 删除消费组：
kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:9092 --group some_customer_group --delete
其他命令
- 平衡Leader：
kafka-preferred-replica-election.sh --bootstrap-server 127.0.0.1:9092
- 压力测试：
kafka-producer-perf-test.sh --topic some_topic--num-records 100 --record-size 1 --throughput 100 --producer-props bootstrap.servers=127.0.0.1:9092
