使用Debezium采集Postgresql数据
文章目录
- 一、前置准备
-
- 安装jdk18
- 获取kafka安装包
- 配置参数
- 二、Postgresql中创建逻辑复制发布
-
- 开启逻辑复制
- 创建Publication（逻辑发布）
- 三、安装debezium插件
-
- 下载debezium-connector-postgresql插件，解压到指定路径
- 三、启动kafka
-
- 启动Zookeeper
- 启动kafka
- 启动kafka connect
- 创建connector（以pg为例）
- 查看连接状态
一、前置准备
提前准备一台机器和一个pg数据库。
安装jdk18
下载jdk18
wget --no-check-certificate --header "Cookie: oraclelicense=accept-securebackup-cookie" \
https://download.oracle.com/java/18/archive/jdk-18.0.2_linux-x64_bin.tar.gz
解压安装包
tar -zxvf jdk-18.0.2_linux-x64_bin.tar.gz -C /usr/local/
重命名目录
sudo mv /usr/local/jdk-18.0.2 /usr/local/jdk18
配置环境变量
vim /etc/profile
export JAVA_HOME=/usr/local/jdk18
export PATH=$JAVA_HOME/bin:$PATH
export CLASSPATH=.:$JAVA_HOME/lib
source /etc/profile
检验java版本
java -version
获取kafka安装包
kafka官网
选择自己需要的版本进行下载，然后上传到CVM上
或者执行以下命令下载（注意版本号需要自行更换）
建议下载二进制包，源码包编译很慢
-- 以下为二进制包
wget<