A. 启动zookeeper:
sh bin/zookeeper-server-start.sh config/zookeeper.properties
如果想继续运行其他命令,不关闭当前窗口,可以加“&“,就可以后台运行了:
sh bin/zookeeper-server-start.sh config/zookeeper.properties &
B. 启动kafka:
sh bin/kafka-server-start.sh config/server.properties
如果想继续运行其他命令,不关闭当前窗口,可以加“&“,就可以后台运行了:
sh bin/kafka-server-start.sh config/server.properties &
C. 创建topic:
sh bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic sports_test
D. 删除topic:
sh bin/kafka-topics.sh --delete --zookeeper localhost:2181 --topic sports_test
E. 创建消息生产者:
sh bin/kafka-console-producer.sh --broker-list localhost:9092 --topic sports_test
F. 创建消费者:
sh bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic sports_test --from-beginning
G. 查看消息服务列表:
sh bin/kafka-topics.sh --list --zookeeper localhost:2181
版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。
文章由极客之家整理,本文链接:https://www.bmabk.com/index.php/post/164175.html