2021年大数据Kafka:❤️kafka的shell命令使用❤️

Posted Lansonli

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了2021年大数据Kafka:❤️kafka的shell命令使用❤️相关的知识,希望对你有一定的参考价值。

全网最详细的大数据Kafka文章系列,强烈建议收藏加关注! 

新文章都已经列出历史文章目录,帮助大家回顾前面的知识重点。

目录

系列历史文章

Kafka的shell命令使用

一、创建topic

二、生产消息到kafka

三、从kafka中消费消息

四、查看主题的命令

五、运行describe的命令

六、 增加topic分区数

七、删除topic 

八、使用kafka Tools操作Kafka 


系列历史文章

2021年大数据Kafka(十二):❤️Kafka配额限速机制❤️

2021年大数据Kafka(十一):❤️Kafka的消费者负载均衡机制和数据积压问题❤️

2021年大数据Kafka(十):kafka生产者数据分发策略

2021年大数据Kafka(九):kafka消息存储及查询机制原理

2021年大数据Kafka(八):Kafka如何保证数据不丢失

2021年大数据Kafka(七):Kafka的分片和副本机制

2021年大数据Kafka(六):❤️安装Kafka-Eagle❤️

2021年大数据Kafka(五):❤️Kafka的java API编写❤️

2021年大数据Kafka(四):❤️kafka的shell命令使用❤️

2021年大数据Kafka(三):❤️Kafka的集群搭建以及shell启动命令脚本编写❤️

2021年大数据Kafka(二):❤️Kafka特点总结和架构❤️

2021年大数据Kafka(一):❤️消息队列和Kafka的基本介绍❤️

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

六、 增加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集群

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

 

3、使用kafka Tools操作Kafka 

创建 topic

查看分区中的数据


  • 📢博客主页:https://lansonli.blog.csdn.net
  • 📢欢迎点赞 👍 收藏 ⭐留言 📝 如有错误敬请指正!
  • 📢本文由 Lansonli 原创,首发于 CSDN博客🙉
  • 📢大数据系列文章会每天更新,停下休息的时候不要忘了别人还在奔跑,希望大家抓紧时间学习,全力奔赴更美好的生活✨

以上是关于2021年大数据Kafka:❤️kafka的shell命令使用❤️的主要内容,如果未能解决你的问题,请参考以下文章

2021年大数据Kafka:❤️Kafka配额限速机制❤️

❤️2021年大数据Kafka:Kafka特点总结和架构

2021年大数据Kafka:❤️Kafka的java API编写❤️

2021年大数据Kafka:❤️Kafka的java API编写❤️

2021年大数据Kafka:❤️消息队列和Kafka的基本介绍❤️

2021年大数据Kafka:❤️消息队列和Kafka的基本介绍❤️