apache-kafka - 使用 Kafka 实现 SQL 更新

Question

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

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

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

你会怎么做？

Answer 1

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

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

相关 -是否有用于更新表中值的 KSQL 语句？