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…...
生成xcframework
打包 XCFramework 的方法 XCFramework 是苹果推出的一种多平台二进制分发格式，可以包含多个架构和平台的代码。打包 XCFramework 通常用于分发库或框架。 使用 Xcode 命令行工具打包 通过 xcodebuild 命令可以打包 XCFramework。确保项目已经配置好需要支持的平台…...
工业安全零事故的智能守护者：一体化AI智能安防平台
前言： 通过AI视觉技术，为船厂提供全面的安全监控解决方案，涵盖交通违规检测、起重机轨道安全、非法入侵检测、盗窃防范、安全规范执行监控等多个方面，能够实现对应负责人反馈机制，并最终实现数据的统计报表。提升船厂…...
【WiFi帧结构】
文章目录 帧结构MAC头部管理帧 帧结构 Wi-Fi的帧分为三部分组成：MAC头部frame bodyFCS，其中MAC是固定格式的，frame body是可变长度。 MAC头部有frame control，duration，address1，address2，addre…...
Go 语言接口详解
Go 语言接口详解 核心概念 接口定义 在 Go 语言中，接口是一种抽象类型，它定义了一组方法的集合： // 定义接口 type Shape interface {Area() float64Perimeter() float64 } 接口实现 Go 接口的实现是隐式的： // 矩形结构体…...
智能AI电话机器人系统的识别能力现状与发展水平
一、引言 随着人工智能技术的飞速发展，AI电话机器人系统已经从简单的自动应答工具演变为具备复杂交互能力的智能助手。这类系统结合了语音识别、自然语言处理、情感计算和机器学习等多项前沿技术，在客户服务、营销推广、信息查询等领域发挥着越来越重要…...
初探Service服务发现机制
1.Service简介 Service是将运行在一组Pod上的应用程序发布为网络服务的抽象方法。 主要功能：服务发现和负载均衡。 Service类型的包括ClusterIP类型、NodePort类型、LoadBalancer类型、ExternalName类型 2.Endpoints简介 Endpoints是一种Kubernetes资源…...
推荐 github 项目:GeminiImageApp(图片生成方向，可以做一定的素材)
推荐 github 项目:GeminiImageApp(图片生成方向，可以做一定的素材) 这个项目能干嘛? 使用 gemini 2.0 的 api 和 google 其他的 api 来做衍生处理 简化和优化了文生图和图生图的行为(我的最主要) 并且有一些目标检测和切割(我用不到) 视频和 imagefx 因为没 a…...
无人机侦测与反制技术的进展与应用
国家电网无人机侦测与反制技术的进展与应用 引言 随着无人机（无人驾驶飞行器，UAV）技术的快速发展，其在商业、娱乐和军事领域的广泛应用带来了新的安全挑战。特别是对于关键基础设施如电力系统，无人机的“黑飞”&…...
华为OD机试-最短木板长度-二分法(A卷,100分)
此题是一个最大化最小值的典型例题， 因为搜索范围是有界的，上界最大木板长度补充的全部木料长度，下界最小木板长度； 即left0,right10^6; 我们可以设置一个候选值x(mid)，将木板的长度全部都补充到x，如果成功…...
恶补电源：1.电桥
一、元器件的选择 搜索并选择电桥，再multisim中选择FWB，就有各种型号的电桥: 电桥是用来干嘛的呢？ 它是一个由四个二极管搭成的“桥梁”形状的电路，用来把交流电（AC）变成直流电（DC）。…...