文件名称：pg2kafka：将Postgres changes中的更改发送到Kafka:open_book:
文件大小：19KB
文件格式：ZIP
更新时间：2024-02-26 16:32:34
golang kafka postgresql stream-processing PostgreSQLGo
pg2kafka 拍摄快照的初始表示后，此服务将触发器添加到Postgres数据库中的给定表中，并跟踪对该表的更改以将其传递给Kafka主题。 它由两部分组成： 数据库中的模式，包含一个outbound_event_queue表以及所有必要的功能和触发器以拍摄快照并跟踪更改。 一个小的可执行文件，从所述表中读取并将其发送到Kafka。 pg2kafka仍在早期开发中，不建议在生产中使用它。 如果遇到问题，请打开一个问题。 我们将其用作可靠地从托管的PostgreSQL数据库中获取数据的方法，在这些数据库中，由于无法访问WAL日志且无法在数据库主机上安装本机扩展或运行二进制文件，因此
【文件预览】：
pg2kafka-master
----Gopkg.toml(150B)
----.gitignore(8B)
----Dockerfile(731B)
----sql()
--------sql_test.go(6KB)
--------migrations.sql(1KB)
--------triggers.sql(3KB)
----main_test.go(4KB)
----LICENSE(738B)
----eventqueue()
--------event_queue.go(5KB)
--------event_queue_test.go(2KB)
----main.go(5KB)
----README.md(5KB)
----script()
--------setup(153B)
--------bootstrap(1KB)
--------build(120B)
--------tests()
--------deploy(137B)
--------test(139B)
----TODO.md(74B)
----Gopkg.lock(3KB)