前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >大数据Kafka(四):kafka的shell命令使用

大数据Kafka(四):kafka的shell命令使用

作者头像
Lansonli
修改2022-10-07 11:08:00
1.2K0
修改2022-10-07 11:08:00
举报
文章被收录于专栏:Lansonli技术博客Lansonli技术博客

Kafka的shell命令使用

一、创建topic

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

代码语言:javascript
复制
# 创建名为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主题中。

代码语言:javascript
复制
bin/kafka-console-producer.sh --broker-list node1:9092 --topic test

三、从kafka中消费消息

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

代码语言:javascript
复制
bin/kafka-console-consumer.sh --bootstrap-server node1:9092 --topic test

四、查看主题的命令

查看 kafka 当中存在的主题

代码语言:javascript
复制
bin/kafka-topics.sh --list --zookeeper node1:2181,node2:2181,node3:2181

五、运行describe的命令

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

代码语言:javascript
复制
bin/kafka-topics.sh --describe --zookeeper node01:2181 --topic test

六、 增加topic分区数

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

代码语言:javascript
复制
bin/kafka-topics.sh --zookeeper zkhost:port --alter --topic topicName --partitions 8

七、删除topic 

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

代码语言:javascript
复制
delete.topic.enable=true

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

代码语言:javascript
复制
bin/kafka-topics.sh --zookeeper zkhost:port --delete --topic topicName

八、使用kafka Tools操作Kafka

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

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

3、使用kafka Tools操作Kafka

创建 topic

查看分区中的数据

本文参与 腾讯云自媒体同步曝光计划,分享自作者个人站点/博客。
原始发表:2021-08-08 ,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • Kafka的shell命令使用
    • 一、创建topic
      • 二、生产消息到kafka
        • 三、从kafka中消费消息
          • 四、查看主题的命令
            • 五、运行describe的命令
              • 六、 增加topic分区数
                • 七、删除topic 
                  • 八、使用kafka Tools操作Kafka
                  领券
                  问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档