使用tunnel采集postgresql数据到kafka

1.下载软件 tunnel

从git上下载源码并打包：

使用格式：

2.开启pg逻辑复制

进入到pg的data目录

修改pg_hba.conf，

修改完后如下内容：

然后运行kafka服务，进入kafka客户端，执行如下命令：

运行成功如图所示：

保存，并退出。

在tunnel客户端下执行如下启动命令：

启动完成，如图所示：

登录到pg数据库进行插入数据，删除数据，更新数据

执行消费者命令：

如图所示：可以看到操作的数据都消费到了，测试成功。

文章知识点与官方知识档案匹配，可进一步学习相关知识PostgreSQL技能树查询数据psql4590 人正在系统学习中

来源：懒猪有梦想