前言为了定位服务所在服务网络数据传输量，需要查看服务【进程】在网卡的传输数据情况流程查看服务进程PIDps -ef / ps aux 的到PID 8630ps aux | grep Test | grep -v greproot86300.30.3 53399460 910268 ?Sl06:010:55 java -cp .:/data/program/JobDispatchMaven/reso

众所周知：python json 可以转换的json字符串，但是在将其转换为字典时，出现了乱序字典是一个散列结构，亦即他自身根据key进行排序，无法保证顺序import jsonjsonstr = '{"username":"string","age":"int","income":"fl

一 kafka某个offset的监控工具(1).开源社区有相应的组件进行监控a.下载 kafka offset监控 (地址链接)https://pan.baidu.com/s/1sj0YERV  (如果失效,可以上社区搜索)b. 解压后发现KafkaOffsetMonitor-assembly-0.2.1.jar,即为监控组件c.编写脚本(可定时启动)KafkaOffsetMonitor...

1.spark streaming 持续如下打印日志,无法进行任务处理,并无报错AbstractCoordinator: (Re-)joining group testpAbstractCoordinator: (Re-)joining group testpAbstractCoordinator: (Re-)joining group testp2.查看zookeeper...

问题描述手动往kafka命令中发送数据，发生截断，导致kafka的数据不完整，flume的采集的数据不完整（以为是flume 采集数据发生truncate):/usr/kafka_2.10-0.9.0.1/bin/kafka-console-producer.sh--topicdp_monitor_rh_out-20190717--broker-listbroker-...

链接: https://pan.baidu.com/s/1ryDl-aF51H6cFTW0hgnS-A提取码: rsth

flink-cdc 抽取数据到kafka 中，使用flink-sql进行开发，相关问题总结

一前言在互联网项目中，随着业务的增加，访问的增长，对系统性能，扩展性，伸缩性提出更高的同时，数据库的压力也陡然增加。越来越多的系统采用分布式系统架构，在数据方面，也采用数据库集群，与此同时，基于系统访问，数据的查询较多，增删改较少，为了减少数据压力，提高系统响效率，采用数据库读写分离也是一个较好的选择。采用此种策略，不仅使提高系统的响应时效，而且利于数据...

本次介绍linux下rpm安装软件，对于一些依赖较少（两个以下）的软件使用rpm安装；若依赖较多，使用yum安装，便于卸载

这里写自定义目录标题查看空间使用查看各个目录使用情况查看当前目录磁盘空间使用情况往下二级级目录使用情况对当前目录的子目录使用空间进行排序按照byte进行排序，其他单位排序不正确截取排序后的前10截取排序后的后10查看空间使用查看各个目录使用情况df -h查看当前目录磁盘空间使用情况包含各个目录，及总使用量 du -h .往下二级级目录使用情况即当前目录的二级子目录使用情况对当前目录的子目录使用空间