最近团队遇到了一个棘手的状态一致性问题。我们的流处理平台核心是 Apache Flink,它消费实时数据,处理后需要同时写入到两个异构系统中:一个用于在线查询的 PostgreSQL 数据库,另一个是用于全文检索的 Elasticsearc
2023-10-27