Flink CDC 菜鸟教程 -环境篇
本教程将介绍如何使用 Flink CDC 来实现这个需求， 在 Flink SQL CLI 中进行，只涉及 SQL，无需一行 Java/Scala 代码，也无需安装 IDE。 系统的整体架构如下图所示：
环境篇
1、 准备一台Linux
2、准备教程所需要的组件
下载 flink-1.13.2 并将其解压至目录 flink-1.13.2
tar zxvf flink-1.13.2-bin-scala_2.12.tgz
✓ flink-1.13.2-bin-scala_2.12.tgz
链接：百度网盘 请输入提取码 提取码：az82
下载下面列出的依赖包，并将它们放到目录 flink-1.13.2/lib/ 下：
✓ flink-sql-connector-mysql-cdc-2.1.0.jar
✓ flink-sql-connector-postgres-cdc-2.1.0.jar
✓ flink-sql-connector-mongodb-cdc-2.1.0.jar
✓ flink-sql-connector-elasticsearch7_2.11-1.13.2.jar
✓ flink-sql-connector-kafka_2.12-1.13.5.jar
✓ flink-shaded-hadoop-2-uber-2.7.5-10.0.jar
✓ iceberg
相关文章：
Flink CDC 菜鸟教程 -环境篇
本教程将介绍如何使用 Flink CDC 来实现这个需求， 在 Flink SQL CLI 中进行，只涉及 SQL，无需一行 Java/Scala 代码，也无需安装 IDE。 系统的整体架构如下图所示： 环境篇 1、 准备一台Linux 2、准备教程所需要的组件 下载 flink-1.13.2 并将其解压至目录 flink-1.13.2 …...
【线上问题】linux部署docker应用docker-compose启动报端口占用问题（感觉上没有被占用）
目录 一、问题说明二、排查过程 一、问题说明 1.linux服务器使用的不是root用户权限 2.docker应用服务没有关闭的情况下，做了些重装docker，重启docker等操作 3.docker-compose up -d然后docker logs查看日志报端口被占用 4.netstat -ntpl | grep 端口 也…...
解决虚拟机克隆后IP和命名冲突问题
目录 解决IP冲突问题 解决命名冲突 解决IP冲突问题 克隆后的虚拟机和硬件地址和ip和我们原虚拟机的相同，我们需要重新生成硬件地址和定义ip，步骤如下： （1）进入 /etc/sysconfig/network-scripts/ifcfg-ens33 配置文件…...
分享一个python基于数据可视化的智慧社区服务平台源码
💕💕作者：计算机源码社 💕💕个人简介：本人七年开发经验，擅长Java、Python、PHP、.NET、Node.js、微信小程序、爬虫、大数据等，大家有这一块的问题可以一起交流！ …...
[密码学入门]凯撒密码
单表代换 单表：英文26字母的顺序 代换：替换为别的字母并保证解密的唯一性 假如我们让加密方式为所有字母顺序移动3位 import stringstring.ascii_lowercase abcdefghijklmnopqrstuvwxyz b3 加密算法y(xb)mod26 解密算法为x(y-b)mod26 密钥空间26 …...
博客之QQ登录功能(一)
流程图 上图spring social 封装了1-8步需要的工作 1、新建包和书写配置文件 public class QQProperties {//App唯一标 识private String appId "100550231";private String appSecret "69b6ab57b22f3c2fe6a6149274e3295e";//QQ供应商private String…...
Redis多机数据库实现
Redis多机数据库实现 为《Redis设计与实现》笔记 复制 客户端可以使用SLAVEOF命令将指定服务器设置为该服务器的主服务器 127.0.0.1:12345> SLAVEOF 127.0.0.1 6379127.0.0.1:6379将被设置为127.0.0.1:123456的主服务器 旧版复制功能的实现 Redis的复制功能分为同步&a…...
Leangoo领歌 -敏捷任务管理软件,任务管理更轻松更透明
任务管理，简单易懂，就是对任务进行管理。那怎么可以更好进行任务管理呢？怎么样样可以让任务进度可视化，一目了然呢？有效的管理可以让我们事半功倍。 接下来我们看一下如何借助任务管理软件高效的做任务管理。 首先…...
go的iris框架进行本地资源映射到服务端
我这里使用的是HandleDirapi,有其他的请补充 package mainimport ("github.com/kataras/iris/v12" )type Hello struct{Status int json:"status"Message string json:"message" }func main(){app : iris.New()//第一个api:相当于首页app.Get(&q…...
代码随想录day46|139. 单词拆分
139. 单词拆分 class Solution:def wordBreak(self, s: str, wordDict: List[str]) -> bool:dp [False]*(len(s)1)dp[0]Truefor i in range(len(s)1):for j in wordDict:if i>len(j) and (s[i-len(j):i] in wordDict) and dp[i-len(j)]:dp[i] Truereturn dp[len(s)]多…...
MATLAB实现函数拟合
目录 一.理论知识 1.拟合与插值的区别 2.几何意义 3.误差分析 二.操作实现 1.数据准备 2.使用cftool——拟合工具箱 三.函数拟合典例 四.代码扩展 一.理论知识 1.拟合与插值的区别 通俗的说，插值的本质是根据现有离散点的信息创建出更多的离散点…...
vue优化首屏加载时间优化-cdn引入第三方包
前言 为什么要进行首屏加载优化，因为随着我们静态资源和第三方包和代码增加，压缩之后包会越来越大 随着网络的影响，在我们第一输入url请求资源时候，网络阻塞，加载时间长，用户体验不好 仔细观察后就会发现…...
lv4 嵌入式开发-3 标准IO的读写
目录 1 标准I/O – 读写流 2 标准I/O – 按字符输入 3 标准I/O – 按字符输出 4 标准I/O – 思考和练习 5 标准I/O – 按行输入 6 标准I/O – 按行输出 7 标准I/O – 思考和练习 1 标准I/O – 读写流 流支持不同的读写方式: 读写一个字符：fgetc()/fputc()一…...
iOS UIDevice设备信息
识别设备和操作系统 //获得共享设备实例 open class var current: UIDevice { get }//识别设备的名称 open var name: String { get } // e.g. "My iPhone"//设备类型 open var model: String { get } // e.g. "iPhone", "iPod touch"//本地化设…...
SLAM ORB-SLAM2（2）编译安装
SLAM ORB-SLAM2（2）编译安装 1. 软件包依赖安装2. 依赖安装2.1. Eigen2.2. Pangolin2.3. OpenCV3. ORB-SLAM23.1. 源码下载3.2. 文件修改3.3. 扩大交换空间3.4. 编译1. 软件包依赖安装 以一个纯净的ubuntu20.04桌面版为例 1.首先设置软件源为清华源 2.安装必要依赖 sudo ap…...
第11节-PhotoShop基础课程-索套工具
文章目录 前言1.索套工具 选中后按Ctrl 可以移动2.加，减，交叉 shift alt 2.多边形索套工具 手动首尾相连 或者双击空地1.单击绘制直线选区2.双击结束绘制3.加，减，交叉4. delete可以删除节点 3.磁性索套工具1.沿着边缘自动吸附2.可…...
Json字符串内容比较-超实用版
背景 之前有类似接口diff对比，数据对比的测试需求，涉及到json格式的数据对比，调研了几个大神们分享的代码，选了一个最符合自己需求的研究了下。 说明 这个对比方法，支持JsonObject和JsonArray类型的数据对比&#x…...
Redis系列之客户端Redisson
概述 官方推荐的客户端，支持Redis单实例、Redis哨兵、Redis Cluster、Redis master-slave等各种部署架构。 GitHub， 功能： 分布式锁 分布式锁 使用Redisson提供的分布式锁的一个最常见场景，应用部署为多个节点，然…...
centos 端口被占用的快速排查方式
问题笔记 centos 端口被占用的快速排查方式 centos 端口被占用的快速排查方式 这里说一个我刚刚遇到的问题，解决步骤用来记录，方便以后自己查询。 nginx配置完index.html测试文件，发现一直显示的404页面。 我跑到服务器上想重启一下nginx …...
Java“牵手”淘宝商品列表数据，关键词搜索淘宝商品数据接口，淘宝API申请指南
淘宝商城是一个网上购物平台，售卖各类商品，包括服装、鞋类、家居用品、美妆产品、电子产品等。要获取淘宝商品列表和商品详情页面数据，您可以通过开放平台的接口或者直接访问淘宝商城的网页来获取商品详情信息。以下是两种常用方法的介绍&…...
[2026 职场洗牌系列 01] 程序员正在“杀死”自己的工作？科技行业高危预警
长久以来，学计算机（CS）在很多年轻人眼里就等同于拿到了通往高薪和阶层跃升的金钥匙。大家都觉得，只要把代码敲得溜，这辈子在职场上基本就稳了。可惜，到了2026年的今天，生成式AI正在毫不留情地把…...
实战指南：基于快马生成电商订单自动化n8n工作流，无缝衔接shopify与crm
实战指南：基于快马生成电商订单自动化n8n工作流，无缝衔接shopify与crm 最近在帮朋友优化他们电商业务的后台流程，发现手动处理订单实在太费时间了。特别是遇到大促期间，订单量暴增，人工操作不仅效率低还容易出错。于是…...
CGAL-6.0.1在Win11与VS2019环境下的高效编译与配置指南
1. 环境准备：搭建Win11VS2019开发环境 在开始编译CGAL-6.0.1之前，我们需要确保开发环境配置正确。我实测发现，Win11系统与VS2019的组合存在一些特殊配置需求，这里分享几个关键检查点： 首先确认VS2019的安装组件。打开V…...
基于主从博弈的主动配电网阻塞管理探索
基于主从博弈的主动配电网阻塞管理 首先，在日前市场中，LA（负荷聚合商）根据历史数据预测次日向上级电网购电的电价信息和预测分布式电源(燃气轮机)出力、风电场出力信息，同时考虑事前与用户签订协议的可中断负荷&#x…...
League-Toolkit：革新英雄联盟体验的效率倍增工具集
League-Toolkit：革新英雄联盟体验的效率倍增工具集 【免费下载链接】League-Toolkit 兴趣使然的、简单易用的英雄联盟工具集。支持战绩查询、自动秒选等功能。基于 LCU API。 项目地址: https://gitcode.com/gh_mirrors/le/League-Toolkit League-Toolkit是一…...
故障发现滞后、处置不及时引发的业务中断与数据风险，超自动化巡检帮您解决
在数字化业务高度依赖IT系统的今天，每一次故障发现滞后、每一次处置不及时，都可能引发连锁反应——从关键业务中断到核心数据泄露，损失往往远超预期。传统运维模式在应对现代复杂系统时已显疲态，而超自动化巡检正成为破解这一困局…...
ffmpegGUI：让FFmpeg视频处理技术大众化的跨平台图形界面工具
ffmpegGUI：让FFmpeg视频处理技术大众化的跨平台图形界面工具 【免费下载链接】ffmpegGUI ffmpeg GUI 项目地址: https://gitcode.com/gh_mirrors/ff/ffmpegGUI ffmpegGUI是一款基于FFmpeg核心技术开发的跨平台图形界面工具，旨在消除视频处理的技术…...
基于LSTM的短期电力负荷预测研究
【负荷预测】基于LSTM短期负荷预测，可考虑需求响应 短期电力负荷预测在电力系统的调度、生产和规划中起着重要的作用，精准的负荷预测有利于决策者做出正确决策计划以及有利于电力系统的稳定运行。 多个售电主体的市场竞争带来了电价的波动，以…...
OpenClaw定时任务管理：Qwen3.5-4B-Claude模型驱动智能提醒系统
OpenClaw定时任务管理：Qwen3.5-4B-Claude模型驱动智能提醒系统 1. 为什么需要AI驱动的定时任务系统 上个月我连续错过了三个重要会议，直到同事发消息询问"人到哪了"才猛然惊醒。这种尴尬促使我开始寻找解决方案——传统日历提醒太被动&#…...
别再只调参了！深入RepVgg设计思想，用CCFF模块优化你的模型特征融合效率
深入解析CCFF模块：用RepVgg思想重构跨尺度特征融合技术 在计算机视觉领域，特征融合一直是提升模型性能的关键环节。传统方法如FPN、PANet虽然有效，但在实时性要求高的场景下往往成为计算瓶颈。今天我们要探讨的CCFF（Cross-scale C…...