LMLPHP后院

扫码查看  原文链接 : https://blog.lmlphp.com/archives/690/Some_commands_of_Kafka  来自 : LMLPHP后院

启动 Zookeeper

bin/zookeeper-server-start.sh config/zookeeper.properties

启动 kafka

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

查看消费组

bin/kafka-consumer-groups.sh --list --bootstrap-server localhost:9092

消费 from beginning

 bin/kafka-console-consumer.sh --topic quickstart-events --from-beginning --bootstrap-server localhost:9092

生产

bin/kafka-console-producer.sh --topic quickstart-events --bootstrap-server localhost:9092

查看 topics

bin/kafka-topics.sh --describe --topic quickstart-events --bootstrap-server localhost:9092

创建主题

 bin/kafka-topics.sh --create --topic quickstart-events --bootstrap-server localhost:9092