学习 Kafka(三):集群管理

命令行工具

终端工具

终端生产者(测试用):

bin/kafka-console-producer.sh --bootstrap-server <Kafka Broker> --topic <主题名>  

终端消费者(测试用):

bin/kafka-console-consumer.sh --bootstrap-server <Kafka Broker 列表> --topic <主题名>  

TOPIC 相关命令

列出所有主题:

bin/kafka-topics.sh --zookeeper <ZK_HOST>:<ZK_PORT> --list  

创建主题:

bin/kafka-topics.sh --zookeeper <ZK_HOST>:<ZK_PORT> --create --topic <主题名> --partitions <分区数> --replication-factor <副本数> --conf <配置项>  

删除主题:

bin/kafka-topics.sh --zookeeper <ZK_HOST>:<ZK_PORT> --delete --topic <主题名>  

消费组相关命令

查看消费组 offset:

bin/kafka-consumer-groups.sh --bootstrap-server <Kafka Broker> --describe --group <消费组名>  

移除消费组:

bin/kafka-consumer-groups.sh --bootstrap-server <Kafka Broker> --delete --group <消费组名>  

Kafka Manager

Kafka Manager 由雅虎开源的 Kafka 集群管理 Web 服务。

TODO

参考