flink cdc 用mybatis-plus写到mysql5.6
背景
项目中需要做一个数据同步的功能， 在方案对比中，canal 与flink cdc 都有尝试。
起初在网上找的flink例子，要么只能支持mysql5.7以上版本，要么就是需要序列化各种bug，比如就不能直接使用 @Autowired xxxServer 来调用数据库层面的注入，getBaseMapper()为空
因为目前mysql用的 5.6版本，所以又用了canal尝试，canal都没有这些问题，
后无意中解决了不兼容mysql5.6问题，现做记录。
为什么没用canal，因为要多安装一个软件，并且cdc还有分布式等优势
目标
实现监控不同的库，不同的表，然后再配合mybatisplus的@DS，最终可以将监听到的数据又可以写到不同库不同表
项目主要代码
yaml
mysql:infos:- ip: 10.53.3.38port: 3306dbs: aauser: rootpwd: roottables: aa.td_device- ip: 10.53.3.38port: 3306dbs: demo2user: rootpwd: roottables: demo2.student2,demo2.td_devicemaven
一定要用这版
相关文章：
flink cdc 用mybatis-plus写到mysql5.6
背景 项目中需要做一个数据同步的功能， 在方案对比中，canal 与flink cdc 都有尝试。 起初在网上找的flink例子，要么只能支持mysql5.7以上版本，要么就是需要序列化各种bug，比如就不能直接使用 @Autowired xxxServer 来调用数据库层面的注入，getBaseMapper()为空 因为目…...
【C++】模板的一点简单介绍
模板 前言泛型编程函数模板概念格式函数模板的原理函数模板的实例化 类模板类模板的定义格式类模板的实例化 前言 这篇博客讲的是模板的一些基本知识，并没有那么深入，但是如果你是为了过期末考试而搜的这篇博客，我觉得下面讲的是够了的。 之…...
SpringCloud概述
前言 什么是微服务？ 微服务是一种面向服务的架构(SOA)风格，其中，应用程序被构建为多个不同的小型服务的集合而不是单个应用程序。与单个程序不同的是，微服务让你可以同时运行多个独立的应用程序，而这些独立的应用…...
Metal入门学习：GPU并行计算大数组相加
一、编程指南PDF下载链接(中英文档） 1、Metal编程指南PDF链接 https://github.com/dennie-lee/ios_tech_record/raw/main/Metal学习PDF/Metal 编程指南.pdf 2、Metal着色语言(Metal Shader Language:简称MSL)编程指南PDF链接 https://github.com/dennie-lee/ios_te…...
关于在spyder，jupyter notebook下创建虚拟环境（pytorch，tensorflow）均有效
anaconda下载地址 https://www.anaconda.com/download/ 下载完成后打开anaconda目录下的 anaconda prompt 在命令行中输入下面的命令创建一个叫tf2.0的虚拟环境（“tf2.0”是建立的Conda虚拟环境的名字，可以自拟） conda create -n tf2.0 p…...
oracle 闪回恢复
oracle 闪回恢复 闪回恢复区主要通过3个初始化参数来设置和管理： db_recovery_file_dest：指定闪回恢复区的位置 db_recovery_file_dest_size：指定闪回恢复区的可用空间大小 db_flashback_retention_target：指定数据库可以回退的时…...
LeetCode 322 零钱兑换
题目： 给你一个整数数组 coins ，表示不同面额的硬币；以及一个整数 amount ，表示总金额。计算并返回可以凑成总金额所需的 最少的硬币个数 。如果没有任何一种硬币组合能组成总金额，返回 -1 。你可以认为每种硬币的数量…...
面试篇SpringMVC是什么以及工作原理
1，什么是SpringMVC呢？ 它是Spring的一种设计模式，一款框架。 2，MVC分别代表什么？ M代表模型即model的缩写，指业务逻辑层模型。V代表视图即View的缩写，指视图层。C则是controller的缩写ÿ…...
jQuery-层级选择器
<!DOCTYPE HTML> <html> <head> <meta http-equiv"Content-Type" content"text/html; charsetUTF-8"> <title>层级选择器</title> <style type"text/css"> …...
【Java数据结构】——第十节(下）.选择排序与堆排序
作者简介：大家好，我是未央； 博客首页：未央.303 系列专栏：Java初阶数据结构 每日一句：人的一生，可以有所作为的时机只有一次，那就是现在！！！ 文章目…...
45道SQL题目陆续更新
文章目录 学习视频配置环境第一天内连接 外连接第二天第三天 学习视频 学习视频 配置环境 四张表 配置四张表的sql语句 #创建发据库 create database frogdata charsetutf8；use frogdata;# 学生表 Student create table Student( SId varchar(10), Sname var…...
在线PS软件有哪些不错的推荐
许多新的UI设计合作伙伴非常关心在线ps工具的选择。现在市场上有各种各样的ps网页替代工具，数量众多，令人眼花缭乱。本文简要介绍了10个在线PS工具，我相信一定有一个适合你！ 1.即时设计 即时设计是一款在线 UI 设计工具…...
Java实现天气预报功能
如果要实现类似百度天气、手机App这样的天气预报功能该如何实现？首先想到的是百度... 背景： 最近公司做了一个项目，天气预报的功能也做上去了，不仅有实时天气、未来7天预报的功能、还有气象预警的功能。 天气包括基本天气、白天夜…...
python循环语句
while循环 Python中，while循环只要在条件（表达式）为真的情况下，就会一直重复执行相应的循环代码块。 while语句的语法格式如下： while 条件表达式：代码块while语句执行的具体流程为：首先判断…...
多线程基础（一）线程基础信息、synchronized 锁概念
1. 基本概念： 程序： 程序是一些保存在磁盘上的指令的有序集合，是静态的。程序包括：内存资源、IO资源、信号处理等。（如：XX.exe） 进程： 进程是程序执行的过程，包括了动态…...
JAVA期末考内容知识点的梳理
作者的话 前言：这些都是很基本的，还有很多没有写出来，重点在于考试复习，包括后四章的内容 前面内容请参考JAVA阶段考内容知识点的梳理 一、集合、流 课堂总结1集合 集合概念： 保存和盛装数据的容器，将许多…...
为什么要使用Thrift与Protocol Buffers？
编码数据的格式 程序通常（至少）使用两种形式的数据： 在内存中，数据保存在对象、结构体、列表、数组、散列表、树等中。 这些数据结构针对 CPU 的高效访问和操作进行了优化（通常使用指针）。如果要将数据写…...
oa是什么意思？oa系统哪个好用？
一、oa是什么意思 oa（Office Automation办公自动化）是一种将智能化科技应用于企业管理中的应用系统。它可以通过电脑网络、互联网等技术手段，将企业的各种业务流程、各种业务数据进行集成和处理，将各种业务流程和各种业务数据统一…...
Linq和C# Lambda表达式
什么是Linq 简介 Linq (Language Integrated Query) 是一种语言集成的查询技术，可以在C#和其他.NET语言中使用。Linq允许我们使用一种类SQL的语言来查询数据，这使得代码更加简洁和易于阅读。Linq提供了一种通用的查询接口，可以用于查询各种…...
蓝桥：前端开发笔面必刷题——Day2 数组（三）
文章目录 📋前言🎯两数之和 II📚题目内容✅解答 🎯移除元素📚题目内容✅解答 🎯有序数组的平方📚题目内容✅解答 🎯三数之和📚题目内容✅解答 📝最后 &#x…...
golang循环变量捕获问题
在 Go 语言中，当在循环中启动协程（goroutine）时，如果在协程闭包中直接引用循环变量，可能会遇到一个常见的陷阱 - 循环变量捕获问题。让我详细解释一下： 问题背景 看这个代码片段： fo…...
FFmpeg 低延迟同屏方案
引言 在实时互动需求激增的当下，无论是在线教育中的师生同屏演示、远程办公的屏幕共享协作，还是游戏直播的画面实时传输，低延迟同屏已成为保障用户体验的核心指标。FFmpeg 作为一款功能强大的多媒体框架，凭借其灵活的编解码、数据…...
剑指offer20_链表中环的入口节点
链表中环的入口节点 给定一个链表，若其中包含环，则输出环的入口节点。 若其中不包含环，则输出null。 数据范围 节点 val 值取值范围 [ 1 , 1000 ] [1,1000] [1,1000]。 节点 val 值各不相同。 链表长度 [ 0 , 500 ] [0,500] [0,500]。 …...
跨链模式：多链互操作架构与性能扩展方案
跨链模式：多链互操作架构与性能扩展方案 ——构建下一代区块链互联网的技术基石 一、跨链架构的核心范式演进 1. 分层协议栈：模块化解耦设计 现代跨链系统采用分层协议栈实现灵活扩展（H2Cross架构）： 适配层…...
数据链路层的主要功能是什么
数据链路层（OSI模型第2层）的核心功能是在相邻网络节点（如交换机、主机）间提供可靠的数据帧传输服务，主要职责包括： 🔑 核心功能详解： 帧封装与解封装 封装： 将网络层下发…...
新能源汽车智慧充电桩管理方案：新能源充电桩散热问题及消防安全监管方案
随着新能源汽车的快速普及，充电桩作为核心配套设施，其安全性与可靠性备受关注。然而，在高温、高负荷运行环境下，充电桩的散热问题与消防安全隐患日益凸显，成为制约行业发展的关键瓶颈。 如何通过智慧化管理手段优化散…...
【HTTP三个基础问题】
面试官您好！HTTP是超文本传输协议，是互联网上客户端和服务器之间传输超文本数据（比如文字、图片、音频、视频等）的核心协议，当前互联网应用最广泛的版本是HTTP1.1，它基于经典的C/S模型，也就是客…...
大学生职业发展与就业创业指导教学评价
这里是引用 作为软工2203/2204班的学生，我们非常感谢您在《大学生职业发展与就业创业指导》课程中的悉心教导。这门课程对我们即将面临实习和就业的工科学生来说至关重要，而您认真负责的教学态度，让课程的每一部分都充满了实用价值。 尤其让我…...
全面解析各类VPN技术：GRE、IPsec、L2TP、SSL与MPLS VPN对比
目录 引言 VPN技术概述 GRE VPN 3.1 GRE封装结构 3.2 GRE的应用场景 GRE over IPsec 4.1 GRE over IPsec封装结构 4.2 为什么使用GRE over IPsec？ IPsec VPN 5.1 IPsec传输模式（Transport Mode） 5.2 IPsec隧道模式（Tunne…...
python报错No module named ‘tensorflow.keras‘
是由于不同版本的tensorflow下的keras所在的路径不同，结合所安装的tensorflow的目录结构修改from语句即可。 原语句： from tensorflow.keras.layers import Conv1D, MaxPooling1D, LSTM, Dense 修改后： from tensorflow.python.keras.lay…...