Logstash的安装和配置
需要注意的是，Logstash的配置文件非常灵活，用户可以根据具体的需求进行修改和扩展，例如增加多个输入源、多个过滤器和多个输出目标等。另外，Logstash还支持多种输入和输出格式，例如文本、日志、JSON、CSV等，以及多种编解码方式。编写Logstash配置文件：Logstash的配置文件是一
zookeeper 常用操作
本博客介绍了zookeeper日常运维管理中的一些常用命令
国际多币种移动平台：换汇+支付(Wise/Revolut)
Wise和Revolut都是英国的金融科技公司，提供数字支付和货币转换服务。两家公司都有相对较低的汇率和佣金费用，以及方便快捷的账户开立和管理流程。Wise主要提供跨境汇款和货币转换服务，而Revolut则提供更广泛的银行账户服务，包括预算管理、交易、保险和投资等。同时，Wise和Revolut都提
elasticsearch创建索引失败报错代码提示400
elasticsearch创建索引失败报错代码提示400。
ROW_NUMBER()、RANK()、DENSE_RANK区别
ROW_NUMBER()、RANK()、DENSE_RANK区别ROW_NUMBER()：排序，不会有重复的排序数值。对于相等的两个数字，排序序号不一致DENSE_RANK()：排序，可有重复值。对于相等的两个数字，排序序号一致RANK()：排序，可有重复值。对于相等的两个数字，排序序号一致，但是总
大数据Doris（四十）：Routine Load基本原理和语法介绍
采样窗口内，允许的最大错误行数。整型，用于设置发送批处理数据的并行度，如果并行度的值超过 BE 配置中的 max_send_batch_parallelism_per_job，那么作为协调点的 BE 将使用 max_send_batch_parallelism_per_job 的值。11、load_
IntelliJ IDEA中下载Maven依赖、maven导入pom包
此方法可以在IDEA中重新下载Maven依赖 1.点击IDEA界面右侧Maven Projects 2.点击小M图标（如下图） 3.等待加载完成，有点长，需等待 4.最后点击两个箭头的小圆圈刷新Reimport即可…第三种:在项目右边找到Maven , 看到刷新图标 , 点击刷新。项目是以pom文件
Dinky: 实时即未来，让 Flink SQL 纵享丝滑--如何本地编译、运行
实时即未来，Dinky 为 Apache Flink 而生，让 Flink SQL 纵享丝滑。Dinky 是一个开箱即用、易扩展，以 Apache Flink 为基础，连接 OLAP 和数据湖等众多框架的一站式实时计算平台，致力于流批一体和湖仓一体的探索与实践。本文讲解window 10环境下，如何
【SpringBoot】在Springboot中怎么设置Kafka自动创建Topic
【代码】【SpringBoot】在Springboot中怎么设置Kafka自动创建Topic。
HDFS中Block size的默认大小
为了确认上述问题的答案，从Hadoop的官网上看了各个版本的说明文档中关于 Data Blocks 的说明，发现是从2.7.3版本开始，官方关于Data Blocks 的说明中，block size由64 MB变成了128 MB的。有的说是Hadoop 1.X版本是64MB，2.X版本是128MB，
flink内存参数配置学习
直接上官网配置 JobManager 内存 | Apache Flink配置 JobManager 内存 # JobManager 是 Flink 集群的控制单元。它由三种不同的组件组成：ResourceManager、Dispatcher 和每个正在运行作业的 JobMaster。本篇文档将介绍
第1关：HDFS 上查看文件块信息
第1关：HDFS 上查看文件块信息 在右侧命令行模式操作，将本地的 /opt 目录上传至 HDFS中 /user/hadoop 目录下，并查找文件块的位置和机架信息，将查找出来的信息保存至本地的 /usr/result.txt 中。
【大数据Hive】Hive 窗口函数使用详解
hive窗口函数使用总结
FeignClient 设置动态url
FeignClient 指定动态url
Hadoop大数据从入门到实战（二）分布式文件系统HDFS
头歌实践教学平台教学课堂大数据从入门到实战 - 第2章 分布式文件系统HDFS。
Rabbitmq-集群
镜像集群虽然支持主从，但主从同步并不是强一致性的，某些情况下可能有数据丢失的风险。因此在RabbitMq的3.8版本以后退出了新的功能：仲裁队列来替代镜像集群。底层采用Raft协议确保主从的数据一致性。RabbitMq是天然支持集群模式。是用来替换镜像队列的。
Flink ON YARN
Flink ON YARN 模式就是使用客户端的方式，直接向Hadoop集群提交任务即可，不需要单独启动Flink进程。
flink1.17.0 集成kafka，并且计算
这里只是做了一个简单的消费kafka的flink例子，消费成功后还可以通过sink发送出去，还可以用transform进行转换，这里后面再演示，如果不对的可以指出。
Apache Kafka - 跨集群数据镜像 MirrorMaker
在分布式系统中，数据镜像是一项重要的功能，它可以将数据从一个集群复制到另一个集群，以保证数据的高可用性和容错性。Apache Kafka是一个流处理平台，它提供了一种跨集群数据镜像的解决方案，可以让用户轻松地将数据从一个Kafka集群复制到另一个Kafka集群。Kafka跨集群数据镜像的实现方式是通
初始化Hive元数据库 bash: schematool: 未找到命令的原因
初始化元数据库：schematool -initSchema -dbType mysql -verbose报错-bash: schematool: 未找到命令
