kafka 清除topic数据脚本
kafka 清除topic数据脚本
- #!/bin/sh
- param=$1
- echo "============="
- echo ${param}
- echo "kafka-topics.sh --zookeeper localhost:2181 --delete --topic ${param}"
- kafka-topics.sh --zookeeper localhost:2181 --delete --topic ${param}
- #打印语句
- echo "kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 2 --partitions 3 --topic ${param}"
- #执行命令
- 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数据脚本相关推荐
- 使用python读取kafka实时topic数据demo,包括安装kafka module
1. 安装kafka module kafka-python安装,转载:https://blog.csdn.net/see_you_see_me/article/details/78468421 1. ...
- 2021BTAJ面试真题详解,kafka查看topic数据内容
一.分布式架构学习路线图 据统计,人的阅读时间在20分钟以内是能够达到全身心投入的,顾文章单张篇幅以后会尽量缩短,但更新会尽量相应频繁一些. 二.计算机软件发展历史 首先我们了解下计算机软件的发展历史 ...
- kafka查看topic数据消费情况
1.查询消费者ID: ./kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:9092 --list 2:查看消费情况 ./kafka-cons ...
- kafka彻底删除topic(cleanup policy)、清除特定topic数据
一.彻底不需要该topic了 假设topic为test-0921 步骤如下: ①$KAFKA/bin/kafka-topics.sh --delete --zookeeper Desktop:2181 ...
- Kafka 不停机修改某一个topic数据保存时间
查看topic信息 ./kafka-topics.sh --describe --zookeeper zk:2181 --topic topicName25/03/08 16:05:29 INFO z ...
- 60-30-012-使用-Kafka不停机删除topic数据(自动建立topic)md
1.视界 2.背景 一次客户有这么一个需求 kafka在不停机的情况下 如何清理掉 kafka中的topic数据? 3.第一种测试 直接删除log日志 为了验证我本地测试. 启动kafka (base ...
- JAVA多线程向kafka的topic各分区中写入本地数据
kafka准备工作: 开启zookeeper服务和kafka服务 zkServer.sh startkafka-server-start.sh /opt/soft/kafka211/config/se ...
- Java kafka监控 topic的数据量count情况,每个topic的Summed Recent Offsets(总结最近的偏移量)
Java使用kafka的API来监控kafka的某些topic的数据量增量,offset,定时查总量之后,然后计算差值,然后就可以算单位间隔的每个topic的增量,kafka监控一般都是监控的吞吐量, ...
- java查看kafka数据量_Java kafka监控 topic的数据量count情况,每个topic的offset,
Java使用kafka的API来监控kafka的某些topic的数据量增量,offset,定时查总量之后,然后计算差值,然后就可以算单位间隔的每个topic的增量,kafka监控一般都是监控的吞吐量, ...
最新文章
- use vue 多个_vue.use 插件系统详解
- 科大星云诗社动态20210826
- 把mysql某一列求和_Laravel 对某一列进行筛选然后求和sum()的例子
- Xcode中Info.plist文件各个键的作用说明【搜藏】
- python怎么模拟浏览器交互_干货分享:python爬虫模拟浏览器的两种方法实例分析(赶紧收藏)...
- 在等待Jakarta EE时
- 怎么让织梦文章按照权重排序
- 2017.4.22 hankson的趣味题 思考记录
- Vue.js项目中,当图片无法显示时则显示默认图片
- 只显示小方格_excel中最有效率的插件——方方格子
- AirPlay 投影到 Mac 看不到选项如何解决?
- java压缩包上传,解压,预览(利用editor.md和Jstree实现)和下载
- Javascript的冒泡排序和二分查找
- [分组背包]Luogu1064 金明的预算方案
- vsto excel决跨表引用值不能更新的问题
- html css js肝撸淘宝官网代码(淘宝web端官网页面+部分js功能实现)
- 华为Mate系列平板手机安装谷歌框架
- 如何把阿拉伯数字转换为中文大写?
- 网页中嵌入QQ和邮箱
- 【转】让电脑更高效的魔法 – 浅谈高效率PC工作环境的简化、净化与建立方法...
热门文章
- istio安装命令整理
- SCALA Linux安装:JAVA.LANG.NUMBERFORMATEXCEPTION: FOR INPUT FOR INPUT STRING: “0X100“
- 解决docker报错: ---> [Warning] IPv4 forwarding is disabled. Networking will not work.
- 启动namenode报错:Journal Storage Directory /var/bigdata/hadoop/full/dfs/jn/dmgeo not formatted
- Scala集合与Java集合的对比
- Python Django Session中存取值常用API
- Python3 数字类型转换
- Java线程池示例:任务窃取线程池WorkStealingPool
- SPI动态加载配置文件
- 虚拟机中克隆一台新的centos7