大数据开发Kafka:kafka的shell命令使用
小职 2021-08-30 来源 :「Lansonli」 阅读 847 评论 0

摘要:本文主要是介绍了大数据开发Kafka:kafka的shell命令使用,通过具体的内容向大家展现,希望对大家大数据Kafka的学习有所帮助。

本文主要是介绍了大数据开发Kafka:kafka的shell命令使用,通过具体的内容向大家展现,希望对大家大数据Kafka的学习有所帮助。

大数据开发Kafka:kafka的shell命令使用

Kafka的shell命令使用

一、创建topic

创建一个topic(主题)。Kafka中所有的消息都是保存在主题中,要生产消息到Kafka,首先必须要有一个确定的主题。

# 创建名为test的主题

bin/kafka-topics.sh --create --bootstrap-server node1:9092 --topic test

# 查看目前Kafka中的主题

bin/kafka-topics.sh --list --bootstrap-server node1:9092

二、生产消息到kafka

使用Kafka内置的测试程序,生产一些消息到Kafka的test主题中。

bin/kafka-console-producer.sh --broker-list node1:9092 --topic test

三、从kafka中消费消息

使用下面的命令来消费 test 主题中的消息。

bin/kafka-console-consumer.sh --bootstrap-server node1:9092 --topic test

四、查看主题的命令

查看 kafka 当中存在的主题

bin/kafka-topics.sh --list --zookeeper node1:2181,node2:2181,node3:2181

五、运行describe的命令

运行 describe 查看 topic 的相关详细信息

bin/kafka-topics.sh --describe --zookeeper node01:2181 --topic test

大数据开发Kafka:kafka的shell命令使用


六、 增加topic分区数

任意 kafka 服务器执行以下命令可以增加 topic 分区数

bin/kafka-topics.sh --zookeeper zkhost:port --alter --topic topicName --partitions 8

七、删除topic 

目前删除 topic 在默认情况下知识打上一个删除的标记,在重新启动 kafka 后才删除。如果需要立即删除,则需要 在server.properties 中配置:

delete.topic.enable=true

然后执行以下命令进行删除 topic

bin/kafka-topics.sh --zookeeper zkhost:port --delete --topic topicName

八、使用kafka Tools操作Kafka 

1、安装Kafka Tools后启动Kafka, 并连接kafka集群

大数据开发Kafka:kafka的shell命令使用


2、安装Kafka Tools后启动Kafka, 并连接kafka集群

大数据开发Kafka:kafka的shell命令使用

 大数据开发Kafka:kafka的shell命令使用


3、使用kafka Tools操作Kafka 


创建 topic

大数据开发Kafka:kafka的shell命令使用

大数据开发Kafka:kafka的shell命令使用


查看分区中的数据

大数据开发Kafka:kafka的shell命令使用





我是小职,记得找我

✅ 解锁高薪工作

✅ 免费获取基础课程·答疑解惑·职业测评

大数据开发Kafka:kafka的shell命令使用

本文由 @小职 发布于职坐标。未经许可,禁止转载。
喜欢 | 0 不喜欢 | 0
看完这篇文章有何感觉?已经有0人表态,0%的人喜欢 快给朋友分享吧~
评论(0)
后参与评论

您输入的评论内容中包含违禁敏感词

我知道了

助您圆梦职场 匹配合适岗位
验证码手机号,获得海同独家IT培训资料
选择就业方向:
人工智能物联网
大数据开发/分析
人工智能Python
Java全栈开发
WEB前端+H5

请输入正确的手机号码

请输入正确的验证码

获取验证码

您今天的短信下发次数太多了,明天再试试吧!

提交

我们会在第一时间安排职业规划师联系您!

您也可以联系我们的职业规划师咨询:

小职老师的微信号:z_zhizuobiao
小职老师的微信号:z_zhizuobiao

版权所有 职坐标-一站式IT培训就业服务领导者 沪ICP备13042190号-4
上海海同信息科技有限公司 Copyright ©2015 www.zhizuobiao.com,All Rights Reserved.
 沪公网安备 31011502005948号    

©2015 www.zhizuobiao.com All Rights Reserved

208小时内训课程