Kafka操作命令[速查]

本文罗列工作中常用的kafka命令，方便工作速查，并会不但更新完善。

集群状态相关命令

1. 启动kafka：

kafka-server-start.sh -daemon server.properties

2. 停止kafka：

kafka-server-stop.sh

Topic相关命令

1. 创建topic：

kafka-topics.sh --create --zookeeper 127.0.0.1:2181 --replication-factor 1 --partitions 1 --topic some_topic

2. 删除topic：

kafka-topics.sh --delete --zookeeper 127.0.0.1:2181 --topic some_topic

3. 查看所有topic：

kafka-topics.sh --list --zookeeper 127.0.0.1:2181

4. 查看指定topic：

kafka-topics.sh --list --zookeeper 127.0.0.1:2181 --topic some_topic

5. 修改topic：

kafka-topics.sh --zookeeper 127.0.0.1:2181 --alter --topic some_topic --partitions 5

生产者相关命令

1. 生产消息：

kafka-console-producer.sh --broker-list 127.0.0.1:9092 --topic some_topic

消费者相关命令

1. 消费消息：

kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092 --topic some_topic --group some_customer_group

2. 消费组列表查询：

kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:9092 --list

3. 查看某个消费组的消费详情：

kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:9092 --describe --group some_customer_group

4. 删除消费组：

kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:9092 --group some_customer_group --delete

其他命令

1. 平衡Leader：

kafka-preferred-replica-election.sh --bootstrap-server 127.0.0.1:9092

2. 压力测试：

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