kafka常用命令

Kafka启动(后台)

bin/kafka-server-start.sh -daemon config/server.properties

创建主题

## 创建 主题 ./kafka-topics.sh --create --zookeeper 127.0.0.1:2181 --replication-factor 副本数 --partitions 分区数 --topic topicName ## 查询 主题 详情描述 ./kafka-topics.sh -zookeeper 127.0.0.1:2181 --describe -topic topicName ## 主题 增加副本 ./kafka-reassign-partitions.sh -zookeeper 127.0.0.1:2181 -reassignment-json-file json/partitions-to-move.json -execute ## 为 主题 增加 分区数 ./kafka-topics.sh –zookeeper 127.0.0.1:2181 –alter –partitions 分区数 –topic topicName ## 删除 主题 ./kafka-topics.sh --zookeeper 127.0.0.1:2181 --delete --topic topicName ## 查看consumer组内消费的offset ./kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zookeeper 127.0.0.1:2181 --group test --topic topicName

查询

## 查询集群描述 ./kafka-topics.sh --describe --zookeeper ## 消费者列表查询 ./kafka-topics.sh --zookeeper 127.0.0.1:2181 --list ## 新消费者列表查询 ./kafka-consumer-groups.sh --new-consumer --bootstrap-server 127.0.0.1:9092 --list ## 显示某个消费组的消费详情（仅支持offset存储在zookeeper上的） ./kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zookeeper 127.0.0.1:2181 --group groupName ## 显示某个消费组的消费详情 ./kafka-consumer-groups.sh --new-consumer --bootstrap-server 127.0.0.1:9092 --describe --group groupName

生产者

## 生产者 ./kafka-console-producer.sh --broker-list 127.0.0.1:9092 --topic test ## 新生产者（支持0.9版本+）+指定配置文件 ./kafka-console-producer.sh --broker-list 127.0.0.1:9092 --topic test --producer.config config/producer.properties

消费者

## 消费者 ./kafka-console-consumer.sh --zookeeper 127.0.0.1:2181 --topic test ## 新消费者（支持0.9版本+）+指定配置文件 ./kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092 --topic test --new-consumer --from-beginning --consumer.config config/consumer.properties ## 指定分区 指定偏移量 返回指定消息数 ./kafka-simple-consumer-shell.sh --brist 127.0.0.1:9092 --topic test --partition 0 --offset 1234 --max-messages 10

其他

## 平衡leader(用于集群中有broker停止或崩溃，leader分配不合理手动执行处理) ./kafka-preferred-replica-election.sh --zookeeper 127.0.0.1:2181/chroot ## 下线broker ./kafka-run-class.sh kafka.admin.ShutdownBroker --zookeeper 127.0.0.1:2181 --broker #brokerId# --num.retries 3 --retry.interval.ms 60 shutdown broker