使用 Kafka 实施 SQL 更新
Implement SQL update with Kafka
如何更新存储在 Kafka 主题/Ktable 中的对象？
我的意思是，如果我不需要替换整个值（压缩的 Ktable 会做），而是单个字段更新。我应该从 topic/Ktable 中读取、反序列化、更新对象，然后将新值存储在相同的 topic/KTable 中吗？
或者我应该 join/merge 2 个主题：一个是原始值，第二个是字段的更新？
你会怎么做？
Kafka（和 RocksDB）存储字节；它无法比较嵌套字段，因为它们是数据库列。为了这样做无论如何都需要反序列化
要更新字段，您需要构造并 post 整个值； JOIN 将有效地做同样的事情
相关 - Is there a KSQL statement to update values in table?
如何更新存储在 Kafka 主题/Ktable 中的对象？
我的意思是，如果我不需要替换整个值（压缩的 Ktable 会做），而是单个字段更新。我应该从 topic/Ktable 中读取、反序列化、更新对象，然后将新值存储在相同的 topic/KTable 中吗？
或者我应该 join/merge 2 个主题：一个是原始值，第二个是字段的更新？
你会怎么做？
Kafka（和 RocksDB）存储字节；它无法比较嵌套字段，因为它们是数据库列。为了这样做无论如何都需要反序列化
要更新字段，您需要构造并 post 整个值； JOIN 将有效地做同样的事情
相关 - Is there a KSQL statement to update values in table?