pg2kafka 拍摄快照的初始表示后，此服务将触发器添加到Postgres数据库中的给定表中，并跟踪对该表的更改以将其传递给Kafka主题。 它由两部分组成： 数据库中的模式，包含一个outbound_event_queue表以及所有必要的功能和触发器以拍摄快照并跟踪更改。 一个小的可执行文件，从所述表中读取并将其发送到Kafka。 pg2kafka仍在早期开发中，不建议在生产中使用它。 如果遇到问题，请打开一个问题。 我们将其用作可靠地从托管的PostgreSQL数据库中获取数据