目前公司 pgsql 数据同步到 es 的方案是 debezium 监听日志发送 kafka ,然后 flink 消费 kafka 做同步 es 的操作。 小弟的疑问是为什么要加 flink 这一步,直接自己起一个 kafka consumer 消费这个变更日志去做同步 es 的处理不行吗,有什么区别吗 Kafka, flink, pgsql, 同步