kafka 清除topic数据脚本

2018年07月25日 16:57:13 pete1223 阅读数:1028

  1. #!/bin/sh
  2. param=$1
  3. echo "============="
  4. echo ${param}
  5. echo "kafka-topics.sh --zookeeper localhost:2181 --delete --topic ${param}"
  6. kafka-topics.sh --zookeeper localhost:2181 --delete --topic ${param}
  7. #打印语句
  8. echo "kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 2 --partitions 3 --topic ${param}"
  9. #执行命令
  10. kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 2 --partitions 3 --topic ${param}

输入 xxx.sh topicname

转载于:https://www.cnblogs.com/vana/p/10201303.html

kafka 清除topic数据脚本相关推荐

  1. 使用python读取kafka实时topic数据demo,包括安装kafka module

    1. 安装kafka module kafka-python安装,转载:https://blog.csdn.net/see_you_see_me/article/details/78468421 1. ...

  2. 2021BTAJ面试真题详解,kafka查看topic数据内容

    一.分布式架构学习路线图 据统计,人的阅读时间在20分钟以内是能够达到全身心投入的,顾文章单张篇幅以后会尽量缩短,但更新会尽量相应频繁一些. 二.计算机软件发展历史 首先我们了解下计算机软件的发展历史 ...

  3. kafka查看topic数据消费情况

    1.查询消费者ID: ./kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:9092 --list 2:查看消费情况 ./kafka-cons ...

  4. kafka彻底删除topic(cleanup policy)、清除特定topic数据

    一.彻底不需要该topic了 假设topic为test-0921 步骤如下: ①$KAFKA/bin/kafka-topics.sh --delete --zookeeper Desktop:2181 ...

  5. Kafka 不停机修改某一个topic数据保存时间

    查看topic信息 ./kafka-topics.sh --describe --zookeeper zk:2181 --topic topicName25/03/08 16:05:29 INFO z ...

  6. 60-30-012-使用-Kafka不停机删除topic数据(自动建立topic)md

    1.视界 2.背景 一次客户有这么一个需求 kafka在不停机的情况下 如何清理掉 kafka中的topic数据? 3.第一种测试 直接删除log日志 为了验证我本地测试. 启动kafka (base ...

  7. JAVA多线程向kafka的topic各分区中写入本地数据

    kafka准备工作: 开启zookeeper服务和kafka服务 zkServer.sh startkafka-server-start.sh /opt/soft/kafka211/config/se ...

  8. Java kafka监控 topic的数据量count情况,每个topic的Summed Recent Offsets(总结最近的偏移量)

    Java使用kafka的API来监控kafka的某些topic的数据量增量,offset,定时查总量之后,然后计算差值,然后就可以算单位间隔的每个topic的增量,kafka监控一般都是监控的吞吐量, ...

  9. java查看kafka数据量_Java kafka监控 topic的数据量count情况,每个topic的offset,

    Java使用kafka的API来监控kafka的某些topic的数据量增量,offset,定时查总量之后,然后计算差值,然后就可以算单位间隔的每个topic的增量,kafka监控一般都是监控的吞吐量, ...

最新文章

  1. use vue 多个_vue.use 插件系统详解
  2. 科大星云诗社动态20210826
  3. 把mysql某一列求和_Laravel 对某一列进行筛选然后求和sum()的例子
  4. Xcode中Info.plist文件各个键的作用说明【搜藏】
  5. python怎么模拟浏览器交互_干货分享:python爬虫模拟浏览器的两种方法实例分析(赶紧收藏)...
  6. 在等待Jakarta EE时
  7. 怎么让织梦文章按照权重排序
  8. 2017.4.22 hankson的趣味题 思考记录
  9. Vue.js项目中,当图片无法显示时则显示默认图片
  10. 只显示小方格_excel中最有效率的插件——方方格子
  11. AirPlay 投影到 Mac 看不到选项如何解决?
  12. java压缩包上传,解压,预览(利用editor.md和Jstree实现)和下载
  13. Javascript的冒泡排序和二分查找
  14. [分组背包]Luogu1064 金明的预算方案
  15. vsto excel决跨表引用值不能更新的问题
  16. html css js肝撸淘宝官网代码(淘宝web端官网页面+部分js功能实现)
  17. 华为Mate系列平板手机安装谷歌框架
  18. 如何把阿拉伯数字转换为中文大写?
  19. 网页中嵌入QQ和邮箱
  20. 【转】让电脑更高效的魔法 – 浅谈高效率PC工作环境的简化、净化与建立方法...

热门文章

  1. istio安装命令整理
  2. SCALA Linux安装:JAVA.LANG.NUMBERFORMATEXCEPTION: FOR INPUT FOR INPUT STRING: “0X100“
  3. 解决docker报错: ---> [Warning] IPv4 forwarding is disabled. Networking will not work.
  4. 启动namenode报错:Journal Storage Directory /var/bigdata/hadoop/full/dfs/jn/dmgeo not formatted
  5. Scala集合与Java集合的对比
  6. Python Django Session中存取值常用API
  7. Python3 数字类型转换
  8. Java线程池示例:任务窃取线程池WorkStealingPool
  9. SPI动态加载配置文件
  10. 虚拟机中克隆一台新的centos7