小编use*_*887的帖子

我计划建立一个 MySQL 到 Kafka 的流程，最终目标是安排一个过程来根据更改的数据重新计算 mongoDB 文档。

这可能涉及直接修补 mongoDB 文档，或运行重新创建整个文档的进程。

我的问题是，如果对 MySQL 数据库的一组更改都与一个 mongoDB 文档相关，那么我不想为每个更改实时重新运行重新计算过程，我想等待更改“解决”，以便我只根据需要运行重新计算过程。

有没有办法“消除”卡夫卡流？例如，Kafka 消费者是否有一个明确定义的模式，我可以用它来实现我想要的逻辑？