Kafka常用命令

安装、部署

官网直接下载tgz包并解压即可

注意: 版本间参数有一定差异,具体以官网文档、对应版本命令的help为准

常用命令

创建topic

创建一个名为test的topic

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

–replication-factor: 副本集数

–partitions: 分区数,建议和broker数量一样

罗列topic

bin/kafka-topics.sh --zookeeper 127.1:2181 --list

查看某具体topic

bin/kafka-topics.sh --zookeeper 127.1:2181 --describe --topic test

启动一个producer

bin/kafka-console-producer.sh --bootstrap-server 127.1:9093 --topic test

启动一个consumer

bin/kafka-console-consumer.sh --bootstrap-server 127.1:9093 --topic test1 --from-beginning

罗列consumer group

bin/kafka-consumer-groups.sh --bootstrap-server 127.1:9093 --list

查看某具体consumer group

bin/kafka-consumer-groups.sh --bootstrap-server 127.1:9093 --describe --group test-consumer

监控

zookeeper broker 信息查看

bin/zookeeper-shell.sh 127.1:2181 ls /brokers/ids

工具

burrow

参考

Kafka官网
Kafka 中文文档 - ApacheCN