1. 查看当前服务器中的所有topic:
    bin/kafka-topics.sh --zookeeper 主机:2181 --list
  2. 创建topic:
    bin/kafka-topics.sh --zookeeper 主机:2181 --create --replication-factor 3 --partitions 1 --topic 名
  3. 删除topic:
    bin/kafka-topics.sh --zookeeper 主机:2181 --delete --topic 名字
    需要server.properties中设置delete.topic.enable=true否则只是标记删除。
  4. 发送消息:
    bin/kafka-console-producer.sh --broker-list 主机:9092 --topic 名字
    >hello world
  5. 消费消息:
    bin/kafka-console-consumer.sh --zookeeper 主机:9092 --topic 名字
    bin/kafka-console-consumer.sh --bootstrap-server 主机:9092 --topic 名字
    bin/kafka-console-consumer.sh --bootstrap-server 主机:9092 --from-beginning --topic 名字
  6. 查看某个topic的情况
    bin/kafka-topic.sh --zookeeper 主机:2181 --describe --topic 名字
  7. 修改分区数:
    bin/kafka-topics.sh --zookeeper 主机:2181 --alter --topic 名字 --partitions 6

kafka命令行操作,topic相关命令相关推荐

  1. cmd中mysql的操作语句,mysql命令行操作大全 mysql命令行操作总结

    摘要 腾兴网为您分享:mysql命令行操作大全 mysql命令行操作总结,悦作业,英语字典,银万财富,小书亭等软件知识,以及webex,过租号,宁夏教育云,百货通,准妈妈课堂,京客隆网上超市,壁纸生成 ...

  2. DOS命令行操作MySQL常用命令

    平时用可视化界面用惯了,如果紧急排查问题,没有安装可视化工具的话,只能通过命令来看了. 以备不时之需,我们要熟悉一下命令行操作MySQL. 打开DOS命令窗口:WIN + R 输入cmd,回车 然后输 ...

  3. windows常用命令行操作及相关快捷方式

    下面是个人总结的windows命令行和常用命令,和大家一起交流下!               本文从命令行基础命令,编写命令快捷键,文件操作命令,service服务操作命令,      启动系统应用 ...

  4. linux重命名的命令行操作,Linux rename命令批量重命名的方法

    Linux的 rename 命令有两个版本,一个是C语言版本的,一个是Perl语言版本的,早期的Linux发行版基本上使用的是C语言版本的,现在已经很难见到C语言版本的了,由于历史原因,在Perl语言 ...

  5. mysql命令行操作大全_mysql命令行操作大全 mysql命令行操作总结

    一.连接MYSQL 格式: mysql -h主机地址 -u用户名 -p用户密码 或者: mysql -u 用户名 -p // 回车后要求输入密码,密码不可见 1.连接本机MYSQL. 打开DOS窗口, ...

  6. U盘、硬盘 相关的(分区隐藏、格式化)命令行操作

    U盘.硬盘 相关的 分区隐藏.格式化 的命令行操作 命令行操作 应用场景 命令行操作 Win+R 打开运行 输入 cmd 回车,进入命令行 diskpart #运行diskpart工具#会弹出新的命令 ...

  7. Mac通过命令行操作mysql

    Mac通过命令行操作mysql 通过命令行启动数据库:终端输入 配置环境变量 在bash_profile文件的最后输入并保持文件 执行bash_profile文件 操作mysql 展示数据库 通过命令 ...

  8. kafka 基础概念、命令行操作(查看所有topic、创建topic、删除topic、查看某个Topic的详情、修改分区数、发送消息、消费消息、 查看消费者组 、更新消费者的偏移位置)

    文章目录 前言 1. 基础概念 Broker Producer Consumer Consumer Group Topic Partition Replica 2. 命令行操作 2.1 查看所有top ...

  9. 【kafka】三、kafka命令行操作

    kafka命令行操作 kafka的相关操作命令脚本文件在bin目录下 查看所有的topic kafka-topics.sh --zookeeper hll1:2181 --list 或 kafka-t ...

  10. 数据仓库 — 07_Kafka的安装与部署(Kafka命令行操作指令、Kafka集群群起脚本、压力测试、节点数量计算、hadoop_zookeeper_flume_kafka群起脚本、默认端口总结)

    文章目录 1 Kafka的安装与配置 2 Kafka命令行操作 2.1 查看当前服务器中的所有topic 2.2 创建topic 2.3 删除topic 2.4 发送消息 2.5 消费消息 2.6 查 ...

最新文章

  1. 网页中图片大小类型等属性不可用
  2. 树莓派 st-link master使用ST-LINK V2下载STM32程序 支持F0 F1 F2 等
  3. spring cloud sleuth在spring中创建span
  4. 代码质量度量标准_Google研发度量改进实践
  5. java anonymous class_java declare anonymous class using proxy api
  6. JS推断浏览器类型与版本号
  7. 怎么让你开发的安卓软件适应更多尺寸的设备
  8. 基于51单片机的避障小车
  9. mysql置疑原因_数据库置疑的处理办法
  10. 德昂祝您圣诞节快乐!
  11. php设置pdf下载加密文件,pdf文件加密方法 PDF文件怎样加密 如何给PDF文件添加打开口令...
  12. 华为mate40pro有没有鸿蒙,mate40pro不能升级鸿蒙吗?我啥也不懂,完蛋了
  13. 《梦幻西游H5》L inux搭建游戏服务器!
  14. 使用you-get下载b站视频
  15. Transitive attribute传递属性
  16. h5模型转化为pb模型,代码及排坑
  17. 智源社区AI周刊No.99:OpenAI发布接近人类水平的语音识别系统Whisper;马毅:智能的计算和科学研究将融合...
  18. 计算机专业毕业设计答辩稿
  19. uniqid() 函数
  20. 大话西游2在线人工服务器,大话西游2服务器地址列表

热门文章

  1. 项目进度经常延误,该怎么破?
  2. 预告:乘风而起,掘金量化——TokenInsight对话首席
  3. 街区尺度下的通勤出行方式挖掘及其影响因子:以北京市为例
  4. 小程序中maring-top、maring-left、maring-right、maring-bottom失效/没有用的原因及解决方案
  5. 浮点型数据判断相等不能直接使用==
  6. 初识Matlab以及Matlab一般性教程
  7. vs2019生成的exe文件在别人电脑运行不了
  8. 世界最牛的25位顶尖大数据科学家
  9. 基础题库:12 甲流疫情死亡率
  10. 关于Dva中.webpackrc的配置