pgstream

pgstream 是一个基于 Go 编写的实时 PostgreSQL WAL（Write-Ahead Log）读取工具，用于捕获数据库的增量变更事件。它通过逻辑复制机制创建复制槽，结合 pgoutput 插件解码 WAL 二进制日志，实时输出 INSERT、UPDATE、DELETE 操作的结构化 JSON 事件，并附带表名、LSN 位置及新旧数据快照。项目轻量、无外部依赖，采用分层架构（连接器-解码器-处理器），支持开箱即用的 CDC 能力。适用于数据库变更观测、审计日志采集、ETL 增量同步、微服务间数据解耦等需要低延迟、可靠变更流的场景。