WAL侦听器 一种帮助实现事件驱动的体系结构的服务。 为了保持系统中数据的一致性，我们将使用事务消息传递-在具有域模型更改的单个事务中发布事件。 该服务允许您使用其逻辑解码功能订阅PostgreSQL数据库中的更改，并将其发布到NATS Streaming服务器。 工作逻辑 为了在PostgreSQL数据库中接收有关数据更改的事件，我们使用标准的逻辑解码模块（ pgoutput ）该模块将从WAL读取的更改转换为逻辑复制协议。 而且我们已经消耗了所有这些信息。 然后，我们仅过滤出所需的事件