使用Debezium、Kafka和Apache Pinot实现基于CDC的数据插入修改Upsert

如何构建流数据管道以捕获 MySQL 数据库更改并通过 Debezium 和 Kafka 将它们流式传输到 Apache Pinot？ Upserting 意味着如果记录不存在则将其插入数据库中，或者如果存在则更新它。流数据管道末端的分析数据库可以从 upserts 中受益，以保持与源数据库的数据一致性。本文探讨了流数据管道的最小可行设置，该管道捕获来自 MySQL 的更改并通过...