我想把存储在mysql和postgres中的数据流到kafka和另一个数据库节点。
我无法访问binlog，并且没有 DELETE 行动，所以我只需要最近拍到 Inserted 或者 Updated 数据。现在我用 Logstash 但ha不可用，因为 Logstash 目前不支持群集。
我想用Flinkcdc代替，但似乎binlog是必需的。有没有其他途径可以通过Flink做到这一点？