Kafka集群常用命令行操作[通俗易懂]

Kafka集群常用命令行操作[通俗易懂]Kafka集群常用命令行操作1、创建topic创建一个名字为test的主题,有三个分区,有两个副本node01执行以下命令来创建topiccd/export/servers/kafka_2.11-1.0.0bin/kafka-topics.sh–create–zookeepernode01:2181–replication-factor2–partitions…

大家好,又见面了,我是你们的朋友全栈君。

Kafka集群常用命令行操作


在这里插入图片描述

1、创建topic

创建一个名字为test的主题, 有三个分区,有两个副本
node01执行以下命令来创建topic

cd /export/servers/kafka_2.11-1.0.0
bin/kafka-topics.sh --create --zookeeper node01:2181 --replication-factor 2 --partitions 3 --topic test

2、查看主题命令

查看kafka当中存在的主题
node01使用以下命令来查看kafka当中存在的topic主题

cd /export/servers/kafka_2.11-1.0.0
bin/kafka-topics.sh  --list --zookeeper node01:2181,node02:2181,node03:2181

3、生产者生产数据

模拟生产者来生产数据
node01服务器执行以下命令来模拟生产者进行生产数据

cd /export/servers/kafka_2.11-1.0.0
bin/kafka-console-producer.sh --broker-list node01:9092,node02:9092,node03:9092 --topic test

4、消费者消费数据

node02服务器执行以下命令来模拟消费者进行消费数据

cd /export/servers/kafka_2.11-1.0.0
bin/kafka-console-consumer.sh --from-beginning --topic test  --zookeeper node01:2181,node02:2181,node03:2181

5、运行describe topics命令

node01执行以下命令运行describe查看topic的相关信息

cd /export/servers/kafka_2.11-1.0.0
bin/kafka-topics.sh --describe --zookeeper node01:2181 --topic test

6、增加topic分区数

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

cd /export/servers/kafka_2.11-1.0.0
bin/kafka-topics.sh --zookeeper node01:2181 --alter --topic topicName --partitions 8

7、增加配置

动态修改kakfa的配置
任意kafka服务器执行以下命令可以增加topic分区数

cd /export/servers/kafka_2.11-1.0.0
bin/kafka-topics.sh --zookeeper node01:2181 --alter --topic test --config flush.messages=1

释:flush.messages : 数据sync到 log文件之前累积的消息条数。

8、删除配置

动态删除kafka集群配置

cd /export/servers/kafka_2.11-1.0.0
bin/kafka-topics.sh --zookeeper node01:2181 --alter --topic test --delete-config flush.messages

9、删除topic

目前删除topic在默认情况下只是打上一个删除的标记,在重新启动kafka后才删除。如果需要立即删除,则需要在
server.properties中配置:
delete.topic.enable=true
然后执行以下命令进行删除topic

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

好了各位,以上就是这篇文章的全部内容了
—————————————————————————————————————————————————
我是小哪吒,一个正在努力的小青年

创作不易,各位的点赞就是我最大的动力。我们下次见
版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请联系我们举报,一经查实,本站将立刻删除。

发布者:全栈程序员-站长,转载请注明出处:https://javaforall.net/140853.html原文链接:https://javaforall.net

(0)
全栈程序员-站长的头像全栈程序员-站长


相关推荐

  • python3基础:操作mysql数据库

    python3基础:操作mysql数据库mysql登陆基本操作:登陆:mysql-uroot-h127.0.0.1-P3306-pmysql-uroot-p(本机不用写host)退出mysql:ctrl+z+回车,或者exit端口号默认是3306,但是可以通过安装目录下的配置文件修改。使用流程引用API模块获取与数据库的连接执行sql语句与存储过程关闭数据库连接安装pymysqlpython3与…

    2022年6月1日
    63
  • PHP Fatal error: Uncaught Error: Call to undefined function posix_getpid()「建议收藏」

    PHP Fatal error: Uncaught Error: Call to undefined function posix_getpid()

    2022年2月12日
    43
  • c++map的基本使用和操作

    c++map的基本使用和操作

    2021年5月19日
    243
  • int(11,2)_算法笔记视频

    int(11,2)_算法笔记视频week1伪代码与时间复杂度伪代码(PseudoCode)这部分略过,基本上表达出自己意思别人也能看懂就行时间复杂度(Timecomplexity)要注意的是f(n)和大O(g(n)),f(n)=O(g(n))算法频度f(n):该算法基本操作需要执行的次数辅助函数g(n):n取无穷时可近似f(n)—》limf(n)/g(n)等于常数时间渐进复杂度O(g(n)):时间复杂度,通常用O(n)表示运行算法的规模下图为展示了时间复杂度之间比较关系部分题型:给定一式子,要求

    2022年8月11日
    2
  • 超视网络视频中间件:H5视频API接口简介

    超视网络视频中间件:H5视频API接口简介超视网络视频中间件H5视频调用接口具有全兼容、全平台支持、纯WEB、免插件、低延时、安全等功能特点,为安防视频播放提供最稳定、可靠、便捷的解决方案。

    2022年10月3日
    2
  • ubuntu 卸载软件命令及方法[通俗易懂]

    ubuntu 卸载软件命令及方法[通俗易懂]1、如果是从UbuntuSoftwareCenter安装的,进入center,找到那个软件,很明显会有“卸载”的按钮;2、如果是tar、gz、zip之类解压就能用,免安装的,直接删除;3、如果是自己下载的deb包安装,或者通过apt-getinstall安装、或者通过添加ppa安装,使用sudoapt-getautoremovesoftware-name来卸载,为了一次卸干净,可以

    2022年10月5日
    2

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注

关注全栈程序员社区公众号