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…...
[2025CVPR]DeepVideo-R1：基于难度感知回归GRPO的视频强化微调框架详解
突破视频大语言模型推理瓶颈，在多个视频基准上实现SOTA性能 一、核心问题与创新亮点 1.1 GRPO在视频任务中的两大挑战 安全措施依赖问题 GRPO使用min和clip函数限制策略更新幅度，导致： 梯度抑制：当新旧策略差异过大时梯度消失收敛困难：策略无法充分优化# 传统GRPO的梯…...
超短脉冲激光自聚焦效应
前言与目录 强激光引起自聚焦效应机理 超短脉冲激光在脆性材料内部加工时引起的自聚焦效应，这是一种非线性光学现象，主要涉及光学克尔效应和材料的非线性光学特性。 自聚焦效应可以产生局部的强光场，对材料产生非线性响应，可能…...
C++：std::is_convertible
C++标志库中提供is_convertible，可以测试一种类型是否可以转换为另一只类型： template <class From, class To> struct is_convertible; 使用举例： #include <iostream> #include <string>using namespace std;struct A { }; struct B : A { };int main…...
智慧工地云平台源码，基于微服务架构+Java+Spring Cloud +UniApp +MySql
智慧工地管理云平台系统，智慧工地全套源码，java版智慧工地源码，支持PC端、大屏端、移动端。 智慧工地聚焦建筑行业的市场需求，提供“平台网络终端”的整体解决方案，提供劳务管理、视频管理、智能监测、绿色施工、安全管…...
《用户共鸣指数（E）驱动品牌大模型种草：如何抢占大模型搜索结果情感高地》
在注意力分散、内容高度同质化的时代，情感连接已成为品牌破圈的关键通道。我们在服务大量品牌客户的过程中发现，消费者对内容的“有感”程度，正日益成为影响品牌传播效率与转化率的核心变量。在生成式AI驱动的内容生成与推荐环境中࿰…...
学校招生小程序源码介绍
基于ThinkPHPFastAdminUniApp开发的学校招生小程序源码，专为学校招生场景量身打造，功能实用且操作便捷。 从技术架构来看，ThinkPHP提供稳定可靠的后台服务，FastAdmin加速开发流程，UniApp则保障小程序在多端有良好的兼…...
零基础在实践中学习网络安全-皮卡丘靶场（第九期-Unsafe Fileupload模块）（yakit方式）
本期内容并不是很难，相信大家会学的很愉快，当然对于有后端基础的朋友来说，本期内容更加容易了解，当然没有基础的也别担心，本期内容会详细解释有关内容 本期用到的软件：yakit（因为经过之前好多期…...
服务器--宝塔命令
一、宝塔面板安装命令 ⚠️ 必须使用 root 用户 或 sudo 权限执行！ sudo su - 1. CentOS 系统： yum install -y wget && wget -O install.sh http://download.bt.cn/install/install_6.0.sh && sh install.sh2. Ubuntu / Debian 系统…...
CVE-2020-17519源码分析与漏洞复现(Flink 任意文件读取)
漏洞概览 漏洞名称：Apache Flink REST API 任意文件读取漏洞CVE编号：CVE-2020-17519CVSS评分：7.5影响版本：Apache Flink 1.11.0、1.11.1、1.11.2修复版本：≥ 1.11.3 或 ≥ 1.12.0漏洞类型：路径遍历&#x…...
七、数据库的完整性
七、数据库的完整性 主要内容 7.1 数据库的完整性概述 7.2 实体完整性 7.3 参照完整性 7.4 用户定义的完整性 7.5 触发器 7.6 SQL Server中数据库完整性的实现 7.7 小结 7.1 数据库的完整性概述 数据库完整性的含义 正确性 指数据的合法性 有效性 指数据是否属于所定…...