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…...
[特殊字符] 智能合约中的数据是如何在区块链中保持一致的？
🧠 智能合约中的数据是如何在区块链中保持一致的？ 为什么所有区块链节点都能得出相同结果？合约调用这么复杂，状态真能保持一致吗？本篇带你从底层视角理解“状态一致性”的真相。 一、智能合约的数据存储在哪里…...
【大模型RAG】拍照搜题技术架构速览：三层管道、两级检索、兜底大模型
摘要 拍照搜题系统采用“三层管道（多模态 OCR → 语义检索 → 答案渲染）、两级检索（倒排 BM25 向量 HNSW）并以大语言模型兜底”的整体框架： 多模态 OCR 层 将题目图片经过超分、去噪、倾斜校正后，分别用…...
Ubuntu系统下交叉编译openssl
一、参考资料 OpenSSL&&libcurl库的交叉编译 - hesetone - 博客园 二、准备工作 1. 编译环境 宿主机：Ubuntu 20.04.6 LTSHost：ARM32位交叉编译器：arm-linux-gnueabihf-gcc-11.1.0 2. 设置交叉编译工具链 在交叉编译之前&#x…...
stm32G473的flash模式是单bank还是双bank？
今天突然有人stm32G473的flash模式是单bank还是双bank？由于时间太久，我真忘记了。搜搜发现，还真有人和我一样。见下面的链接：https://shequ.stmicroelectronics.cn/forum.php?modviewthread&tid644563 根据STM32G4系列参考手…...
STM32+rt-thread判断是否联网
一、根据NETDEV_FLAG_INTERNET_UP位判断 static bool is_conncected(void) {struct netdev *dev RT_NULL;dev netdev_get_first_by_flags(NETDEV_FLAG_INTERNET_UP);if (dev RT_NULL){printf("wait netdev internet up...");return false;}else{printf("loc…...
Neo4j 集群管理：原理、技术与最佳实践深度解析
Neo4j 的集群技术是其企业级高可用性、可扩展性和容错能力的核心。通过深入分析官方文档，本文将系统阐述其集群管理的核心原理、关键技术、实用技巧和行业最佳实践。 Neo4j 的 Causal Clustering 架构提供了一个强大而灵活的基石，用于构建高可用、可扩展且一致的图数据库服务…...
基于Docker Compose部署Java微服务项目
一. 创建根项目 根项目（父项目）主要用于依赖管理 一些需要注意的点： 打包方式需要为 pom<modules>里需要注册子模块不要引入maven的打包插件，否则打包时会出问题 <?xml version"1.0" encoding"UTF-8…...
代码随想录刷题day30
1、零钱兑换II 给你一个整数数组 coins 表示不同面额的硬币，另给一个整数 amount 表示总金额。 请你计算并返回可以凑成总金额的硬币组合数。如果任何硬币组合都无法凑出总金额，返回 0 。 假设每一种面额的硬币有无限个。 题目数据保证结果符合 32 位带…...
AirSim/Cosys-AirSim 游戏开发（四）外部固定位置监控相机
这个博客介绍了如何通过 settings.json 文件添加一个无人机外的 固定位置监控相机，因为在使用过程中发现 Airsim 对外部监控相机的描述模糊，而 Cosys-Airsim 在官方文档中没有提供外部监控相机设置，最后在源码示例中找到了，所以感…...
Windows 下端口占用排查与释放全攻略
Windows 下端口占用排查与释放全攻略 在开发和运维过程中，经常会遇到端口被占用的问题（如 8080、3306 等常用端口）。本文将详细介绍如何通过命令行和图形化界面快速定位并释放被占用的端口，帮助你高效解决此类问题。 一、准…...