kafka常用命令

生产者

kafka-console-producer.sh --broker-list node:9092 --topic my_topic

消费者

kafka-console-comsumer.sh --bootstrap-server node:9092 --topic my_topic

从头开始消费

kafka-console-consumer.sh --bootstrap-server node:9092 --topic my_topic --from-beginning

创建topic

kafka-topic.sh --create --zookeeper node:2181 --replication-factor 1 --partiton 1 --topic my_topic

列出所有的topic

kafka-topic.sh --list --zookeeper node:2181

查询所有的topic的信息

kafka-topic.sh --describle --zookeeper node:2181

查询指定的topic的信息

kafka-topic.sh --describle --zookeeper node:2181 --topic my_topic

删除topic

kafka-topic.sh --delete --zookeeper node:2181 --topic my_topic

kafka集群启动

kafka-server-start.sh server.properties
这里的server.properties就是kafka启动的配置文件

kafka关闭的命令

kafka-server-stop.sh