发简信
IP属地：云南
-
【Kafka小试】Kafka 高可用机制
Kafka的Replica kafka的topic可以设置有n个副本（replica），副本数最好要小于等于broker的数量，也就是要保证一个...
-
【Flink小试】Flink CDC DataStream API监听MySQL动态发往Kafka Topic
[toc] 一、背景 业务背景: MySQL增量数据实时更新同步到Kafka中供下游使用 查看了一下Flink CDC的官方文档[https:/...
-
SpringBoot @Scheduled多线程执行
问题 在用springboot框架做定时任务的时候，大部分情况都是直接通过@Scheduled注解来指定定时任务的。但是当你有多个定时任务时，@...
-
Go mongo driver使用
通过go mod下载官方driver包go.mongodb.org/mongo-driver 一、初始化设置 创建init.go 二、 创建数据...
-
Go Tools -- 数组收纳数组相关的操作工具 1. 两个数组并集 2. 两个数组交集 3. 两个数组差集 4. 数组是否包含元素 5. 去除数组中的重复元素 Test...
-
二叉树遍历方式题目： 已知一棵二叉树前序遍历和中序遍历分别为ABDEGCFH和DBGEACHF，则该二叉树的后序遍历结果为？ 思路： 根据根节点遍历顺序记遍历...
-
MongoDB Spark Connector使用
背景 对现有的存储在MongoDB中的海量数据进行清洗操作。为了提供数据的处理速度，决定使用spark作为引擎对数据进行操作。 先决条件 Mon...
-
数据仓库中的ODS DW DM理解1. DW 1.1 简介 data warehouse(可简写为DW或DWH)数据仓库,是在数据库已经大量存在的情况下，为了进一步挖掘数据资源、...
-
Go创建Kafka生产者和消费者
1. 定义Producer和Consumer结构体 2. 获取Producer实例 3. 发送数据到Kafka 批量发送 单条发送 4. 通过C...