RabbitMQ（三）【管理界面及授权操作】
默认情况下只能在localhost本机下访问，所以需要添加一个远程登陆的用户。在本地访问http://ip:15672/RabbitMQ 管理界面。解决方法: 授权账号和密码。
延迟队列与SpringBoot实战
延迟队列
kafka send data 超时问题 报错：xx ms has passed since last append
kafka报错：xx ms has passed since last append / xx ms has passed since batch creation plus linger time / ms has passed since last attempt plus backoff ti
hive sql—开窗函数—累积求和和滑动求和
hive sql—开窗函数—累积求和和滑动求和
RabbitMQ实现延时消息的两种方法
因此我们只需要在声明正常的业务队列时添加一个可选的"x-dead-letter-exchange"参数，值为死信交换机，死信就会被rabbitmq重新publish到配置的这个交换机上，我们接着监听这个交换机就可以了。如果当一个队列各个消息的过期时间不一致时，使用死信队列就可能达不到延时的作用。当我
Apache Doris 系列：Bucket(分桶)数量设置建议
Apache Doris集群上线运行一段时间后，随着越来越多的数据增长，集群每次重启后一周左右，读写就会开始变得越来越慢，直到无法正常进行读写。注：表的数据量可以通过 SHOW DATA。命令查看，结果除以副本数，即表的数据量。
Hadoop学习-6-HDFS权限管理
HDFS权限管理
Zookeeper的选举机制
Zookeeper的选举机制
中富金石股票投资机构靠谱吗？机构实力怎么样？
股票市场变化多端，不论是资深股民还是新手小白，选择一个专业靠谱的机构，对自己的投资会有很大的促进作用。风险是一定存在的，但只要我们掌握一定的金融投资知识、有投资顾问进行指导，便能在一定程度上降低风险。面对各有侧重的投教机构该如何选择呢？中富金石在国内有超20年的经验，熟知A股市场变化，各个投资顾问、
Kafka消费者无法消费数据，解决
解决Kafka消费者无法消费数据问题
Kafka进阶篇-消费者详解&Flume消费Kafka原理
Kafka进阶篇-消费者详解&Flume消费Kafka原理
【复盘】记录一次类型不一致导致的Kafka消费异常问题
记录一次生产事故
Python 数据可视化-文本可视化（词云图）
制作自定义个性化词云图
Flink CDC SQL Oracle to Postgresql与jdbc连接oracle报错处理
Flink CDC SQL Oracle to Postgresql与jdbc连接oracle报错处理
Flink+hadoop部署及Demo
上传并解压到3台服务器配置3台主机的hosts和免密登录。
浅谈流程分类和规划
流程本身抽丝剥茧之后，无非是流程属性的分类、分级、流程价值的度量指标。而分类和分级，本身就是一门智慧。一个好的规划，比过于细致的工作要有效果。
大数据技术之Kafka
入门Kafka消息队列，基础架构，分区 ，生产者 ，KafKa Broker , 消费者 ，偏移量offset，精确一致性消费
Apache Kafka - 灵活控制Kafka消费_动态开启/关闭监听实现
在实际应用中，往往需要根据业务需求动态开启/关闭Kafka消费者监听。例如，在某些时间段内，可能需要暂停对某个Topic的消费，或者在某些条件下才开启对某个Topic的消费。在Spring Boot中，要实现动态的控制或关闭消费以及动态开启或关闭监听，可以使用Spring Kafka提供的一些功能。
springcloud(nacos)集成Kafka
Autowired/*** kafka发送手机短信的方法*/log.info("功能名称:发生验证码的方法,请求路径:[{}],请求方法:[{}],请求参数:[{}]",request.getRequestURI()// 获取短信验证码// 存入redis// 异步发生kaklog.info("功能
Pyspark 基础知识
Pyspark基础知识，包括Pyspark基本介绍，和Spark框架对比，WordCount执行流程，Pyspark执行原理等
