聊聊hdfs中的rpc问题
hdfs中的rpc问题
记一次rabbitmq消息发送成功，消费丢失问题
Trace 是Rabbitmq用于记录每一次发送的消息，方便使用Rabbitmq的开发者调试、排错。可通过插件形式提供可视化界面。
springboot集成flink步骤，及demo
springboot集成flink步骤，及demo
Flink（一）1.12.7或1.13.5详细介绍及本地安装部署、验证
本示例以1.12版本进行介绍，当前版本更新至1.17。Flink 诞生于欧洲的一个大数据研究项目 StratoSphere。该项目是柏林工业大学的一个研究性项目。早期， Flink 是做 Batch 计算的，但是在 2014 年， StratoSphere 里面的核心成员孵化出 Flink，同年将
什么是HBase
HBase是一个基于Hadoop的分布式列式存储系统，可以存储非结构化和半结构化的大数据，具有高可用性、高扩展性、高性能等特点，常用于大规模实时数据处理。
RocketMQ源码分析
RocketMQ源码分析
开启hadoop的命令和方法
要开启 Hadoop，你需要进入 Hadoop 的安装目录，然后输入以下命令：sbin/start-dfs.shsbin/start-yarn.sh这会启动 Hadoop 的两个核心组件：Hadoop Distributed File System (HDFS) 和 Yet Another Reso
rabbitmq 开启 virtual host
由于我的rabbitmq架设在测试服务期。导致我本地测试的mq消息，经常被服务器消费掉。所以通过添加v-host，可以创建专属v-host域下的消息进行生产和消费。
【docker深入浅出】一文学透Docker基础万字好文
Docker 最初是dotCloud公司创始人Solomon Hykes在法国期间发起的一个公司内部项目，它是基于dotCloud公司多年云服务技术的一次革新，并与2013年3月以Apache 2.0授权协议开源），主要项目代码在GitHub上进行维护。Docker项目后来还加入了Linux基金会，
java:Kafka生产者推送数据与消费者接收数据（参数配置以及案例）
java kafka 生产者消费者配置 以及参考
【Hadoop 01】简介
Hadoop适合海量数据分布式存储和分布式计算Java改为支持8及以上HDFS支持纠删码HDFS支持多NameNodeMR任务级本地优化多重服务默认端口变更Hadoop主要包含三大组件：HDFS+MapReduce+YARNHDFS负责海量数据的分布式 存储MapReduce是一个计算模型，负责海量
docker-compose 安装 Kafka 3.X 附带可视化界面
docker-compose 安装 Kafka 3.X 附带可视化界面
数据中台OneID：详解ID-Mapping！
ID-Mapping，一文搞定
sql数据类型映射与数据类型转换
MaxCompute 2.0新增了DECIMAL类型与DATETIME的常量定义方式，100BD是数值为100的DECIMAL，2017-11-11 00:00:00是DATETIME类型的常量。关于CAST的介绍请参见CAST。关系运算符包括=、<>、<、<=、>、>=、IS NULL、IS NO
Window下搭建kafka运行环境
Window下搭建kafka运行环境
【hadoop】Linux安装和配置
安装和配置Linux，修改时间2023/7/5
DataX mysql同步到mysql
使用Datax web创建同步任务
ThingsBoard调试部署和性能分析
Thingsboard部署、前端调试部署，开源系统的性能分析
Flink CDC、OGG、Debezium等基于日志开源CDC方案对比
CDC 的全称是，在广义的概念上，只要能捕获数据变更的技术，我们都可以称为 CDC。我们目前通常描述的CDC 技术主要面向数据库的变更，是一种用于捕获数据库中数据变更的技术。
Flink Direct Reader访问Hive ACID表被ranger授权限制
Flink Direct Reader 绕过了 Hive Thrift 接口，直接读取 Hive ACID 表的数据文件，因此无法受到 Ranger 的授权限制。要在受到 Ranger 鉴权的环境中访问 Hive ACID 表，可以考虑使用 Hive Thrift 接口或配置适当的 Ranger 授
