修改ZooKeeper Kafka底层offset值
连接到ZooKeeper cd zookeeper路径/bin ./zkCli.sh -server 127.0.0.1:2181,127.0.0.2:2181, 查看Topic当前分区的offset值 #解释 ae_spark是我的Topic 0是我的分区 get /consumers/ae_spark/offsets/ae_spark/0 以上…
清理Hadoop集群磁盘
查看集群文件占用磁盘情况 hdfs dfs -du -h / 可清理的目录 /tmp /sparkhistoryserver 进入目录找到历史无用的文件 hdfs dfs -du -h /tmp hdfs dfs -du -h /sparkhistoryserver 删除无用的文件 hdfs dfs -rm -r /文件 清掉删除后移动到回收站的文…
thumbnail
初学GoLang,拷贝文件
如需执行需要进入到该文件所在的目录,然后运行如下命令: go run File.go 代码如下: package main import ( "bufio" "fmt" "io" "os" ) // CopyFile destPath 目标文件路径 srcPath 源文件路径 func CopyFile(destPath string, srcPa…
thumbnail
上传jar包到本地maven仓
当直接把jar包复制进maven仓以后,但是不生效,清idea缓存也没用,这个时候用这个方法可以时期生效 命令如下: mvn install:install-file -DgroupId=com.nascent -DartifactId=nascent-ecrp-sdk -Dversion=5.0.3 -Dpackaging=jar -Dfile=…
maven 删除.lastUpdated文件脚本
Mac: vi delete_mvn_lastUpdated.sh # 这里写你的仓库路径 REPOSITORY_PATH=/Users/anran/Documents/Applications/Maven/repository echo 正在搜索... find $REPOSITORY_PATH -name "*lastUpdated*" | x…
SpringBoot项目启动、停止,重启 脚本
编写脚本 脚本和其他博客类似,我是利用其他博客的脚本进行编写,发现各种报错,如不能启动、不能停止等等问题,于是将这些全都修改了,如下: #!/bin/sh #定义程序名 及jar包的名(写上你自己的jar包) PROJECT_NAME=xxx.jar ## 编写判断程序是否正在运行的方法 isExist(){ ## 首先查找进程号 ,这里需要注意一…
Kafka 常用指令
一、概述 本文以 kafka_2.5.1 版本为例,描述的常用命令,在 3.x 版本上命令有所不同。 二、主要命令 kafka启动命令:nohup bin/kafka-server-start.sh config/server.properties & kafka停止命令:bin/kafka-serv…
升级jetty后日志不输出解决方案
修复jetty漏洞升级新版本后日志不输出解决方案 新版的jetty得手动配置 jetty.xml 先执行 java -jar start.jar --add-to-start=console-capture 开启jetty日志打印功能再执行java -jar start.jar --add-to-start=requestlog 开启日志重定向