首页 / 大数据 / 大数据入门第十七天——storm上游数据源 之kafka详解（二）常用命令

大数据入门第十七天——storm上游数据源 之kafka详解（二）常用命令

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了大数据入门第十七天——storm上游数据源 之kafka详解（二）常用命令，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含750字，纯文字阅读大概需要2分钟。

内容图文

一、kafka常用命令

1.创建topic 

                bin/kafka-topics.sh --create --topic topic_1 --partitions 4 --replication-factor 2 --zookeeper mini1:2181

// 如果配置了PATH可以省略相关命令路径，相关命令参数暂不深入，字面意思也可以大概推断。后续给出完整参数参考。

2.查看所有topic 

                bin/kafka-topics.sh --list --zookeeper  mini1:2181

3.发送消息 

                bin/kafka-console-producer.sh --broker-list mini1:9092 --topic topic_1

4.消费消息 

                bin/kafka-console-consumer.sh --zookeeper mini1:2181 --from-beginning --topic topic_1

// 可以在Mini2上消费，是分布式的

5.删除topic 

                bin/kafka-topics.sh --delete --zookeeper mini1:2181 --topic topic_1
需要server.properties中设置delete.topic.enable=true否则只是标记删除或者直接重启。

6.查看topic详情 

                bin/kafka-topics.sh --topic topic_1 --describe --zookeeper mini1:2181

 

原文：https://www.cnblogs.com/jiangbei/p/8542228.html

内容总结

以上是互联网集市为您收集整理的大数据入门第十七天——storm上游数据源 之kafka详解（二）常用命令全部内容，希望文章能够帮你解决大数据入门第十七天——storm上游数据源 之kafka详解（二）常用命令所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/1218662.html

来源：【匿名】