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…...
【英飞凌 CY8CKIT-062S2-AI评测】---姗姗来迟的开箱与环境搭建
一、引言 实话实说，这是英飞凌进驻21ic后的第一次接触到英飞凌的产品，因此收到开发板有段时间了，但一直在摸索当中，平时时间也比较有限，这不赶上了明天（11月3日）英飞凌在线下举办的AI研讨会&…...
Kettle8.2转换组件实战：利用增加序列实现Excel数据自动编号
1. 为什么需要给Excel数据自动编号？ 每次处理Excel数据时，最头疼的就是要给每行数据加个序号。手动添加不仅效率低，还容易出错。上周我帮市场部处理3000多条客户数据，就因为手工编号搞错顺序，差点引发数据混乱。这时候…...
bitcoin-arbitrage自动化交易实战：TraderBot和TraderBotSim详解
bitcoin-arbitrage自动化交易实战：TraderBot和TraderBotSim详解 【免费下载链接】bitcoin-arbitrage Bitcoin arbitrage - opportunity detector 项目地址: https://gitcode.com/gh_mirrors/bi/bitcoin-arbitrage 在加密货币交易领域，利用不同交易…...
终极Windows与Office激活指南：5分钟完成智能激活的完整解决方案
终极Windows与Office激活指南：5分钟完成智能激活的完整解决方案 【免费下载链接】KMS_VL_ALL_AIO Smart Activation Script 项目地址: https://gitcode.com/gh_mirrors/km/KMS_VL_ALL_AIO 你是否曾为Windows系统或Office办公套件的激活问题而烦恼？…...
思源宋体CN：7种字重完全免费的专业中文字体解决方案
思源宋体CN：7种字重完全免费的专业中文字体解决方案 【免费下载链接】source-han-serif-ttf Source Han Serif TTF 项目地址: https://gitcode.com/gh_mirrors/so/source-han-serif-ttf 还在为专业设计中的字体选择而烦恼吗？Source Han Serif CN&…...
终极指南：用TegraRcmGUI轻松解锁Nintendo Switch的无限潜力
终极指南：用TegraRcmGUI轻松解锁Nintendo Switch的无限潜力 【免费下载链接】TegraRcmGUI C GUI for TegraRcmSmash (Fuse Gele exploit for Nintendo Switch) 项目地址: https://gitcode.com/gh_mirrors/te/TegraRcmGUI 还在为Nintendo Switch的封闭系统感到…...
开源软件的商业可持续性：爱、热血与面包的难题
在当今软件测试领域，开源工具如Selenium、JMeter和Postman已成为从业者的日常利器，它们以零成本、高灵活性和社区驱动的优势，大幅提升了测试效率和协作水平。然而，这些工具背后隐藏着一个尖锐矛盾：开源项目的维护者往往…...
PTP时间同步：从报文结构到协议实现
1. PTP协议基础：从时钟同步到报文分类 想象一下，你正在组织一场跨洲视频会议，纽约、伦敦、东京的同事需要同时看到演示文档翻页。如果三地电脑时钟误差超过1秒，就会出现有人提前看到下一页的尴尬场景。这就是**精确时间协议&#…...
国产化替代实战：HC32F460平台FreeModbus RTU从站移植与调试全记录
1. 为什么选择HC32F460进行国产化替代 最近几年，国产芯片的崛起给工程师们带来了新的选择。我在实际项目中接触到小华半导体的HC32F460系列芯片时，第一感觉就是它的性能参数相当亮眼。这款芯片采用ARM Cortex-M4内核，主频高达168MHzÿ…...
从零到一：在Vitis平台上构建ZYNQ PS-SPI Flash驱动
1. 环境准备与硬件连接 在开始构建ZYNQ PS-SPI Flash驱动之前，我们需要准备好开发环境和硬件平台。我推荐使用Xilinx官方提供的Vitis 2022.1版本，这个版本对ZYNQ系列的支持比较稳定。硬件方面，你需要一块带有SPI Flash的ZYNQ开发板࿰…...