240 发简信
fantasticMao
IP属地：四川
  • 【Kafka小试】Kafka 高可用机制

    Kafka的Replica kafka的topic可以设置有n个副本（replica），副本数最好要小于等于broker的数量，也就是要保证一个...

    0.2 1189 0 1
  • 【Flink小试】Flink CDC DataStream API监听MySQL动态发往Kafka Topic

    [toc] 一、背景 业务背景: MySQL增量数据实时更新同步到Kafka中供下游使用 查看了一下Flink CDC的官方文档[https:/...

    5.4 5094 5 10
  • SpringBoot @Scheduled多线程执行

    问题 在用springboot框架做定时任务的时候，大部分情况都是直接通过@Scheduled注解来指定定时任务的。但是当你有多个定时任务时，@...

    0.3 7416 0 2
  • Go mongo driver使用

    通过go mod下载官方driver包go.mongodb.org/mongo-driver 一、初始化设置 创建init.go 二、 创建数据...

    0.3 7208 0 2
  • Resize,w 360,h 240
    Go Tools -- 数组

    收纳数组相关的操作工具 1. 两个数组并集 2. 两个数组交集 3. 两个数组差集 4. 数组是否包含元素 5. 去除数组中的重复元素 Test...

    0.3 262 0 1
  • Resize,w 360,h 240
    二叉树遍历方式

    题目： 已知一棵二叉树前序遍历和中序遍历分别为ABDEGCFH和DBGEACHF，则该二叉树的后序遍历结果为？ 思路： 根据根节点遍历顺序记遍历...

    0.9 384 1 1
  • MongoDB Spark Connector使用

    背景 对现有的存储在MongoDB中的海量数据进行清洗操作。为了提供数据的处理速度，决定使用spark作为引擎对数据进行操作。 先决条件 Mon...

    0.5 5053 0 2
  • Resize,w 360,h 240
    数据仓库中的ODS DW DM理解

    1. DW 1.1 简介 data warehouse(可简写为DW或DWH)数据仓库,是在数据库已经大量存在的情况下，为了进一步挖掘数据资源、...

    0.6 33413 3 10
  • Go创建Kafka生产者和消费者

    1. 定义Producer和Consumer结构体 2. 获取Producer实例 3. 发送数据到Kafka 批量发送 单条发送 4. 通过C...

    0.8 7486 0 4
个人介绍
一名平庸的程序员