pg2kafka:将Postgres changes中的更改发送到Kafka:open_book: 源码

pg2kafka 拍摄快照的初始表示后,此服务将触发器添加到Postgres数据库中的给定表中,并跟踪对该表的更改以将其传递给Kafka主题。 它由两部分组成: 数据库中的模式,包含一个outbound_event_queue表以及所有必要的功能和触发器以拍摄快照并跟踪更改。 一个小的可执行文件,从所述表中读取并将其发送到Kafka。 pg2kafka仍在早期开发中,不建议在生产中使用它。 如果遇到问题,请打开一个问题。 我们将其用作可靠地从托管的PostgreSQL数据库中获取数据的方法,在这些数据库中,由于无法访问WAL日志且无法在数据库主机上安装本机扩展或运行二进制文件,因此