使用 Kafka 实现 SQL 更新答案

【问题标题】：Implement SQL update with Kafka使用 Kafka 实现 SQL 更新
【发布时间】：2021-09-09 08:29:44
【问题描述】：

如何实现对存储在 Kafka 主题/Ktable 中的对象的更新？

我的意思是，如果我不需要替换整个值（压缩的 Ktable 会这样做），而是更新单个字段。我应该从主题/KTable 中读取、反序列化、更新对象，然后将新值存储在同一主题/KTable 中吗？

或者我应该加入/合并 2 个主题：一个具有原始值，第二个具有字段更新？

你会怎么做？

【问题讨论】：

【解决方案1】：

Kafka（和 RocksDB）存储字节；它无法比较嵌套字段，因为它们是数据库列。为此，无论如何都需要反序列化

要更新字段，您需要构造并发布整个值；一个 JOIN 将有效地做同样的事情

【讨论】：