kafka常用命令
2019-12-02 本文已影响0人
程序员的交流电
生产者
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