如何更新Kafka/Kafka流中的数据？

Question

假设有Kafka主题顺序。数据以JSON格式存储：

{
   "order_id": 1,
   "status": 1
}

Status定义订单的状态（待定-1，已完成-2）。

完成后如何在“已完成”上进行更改？

正如我所知，Kafka主题是不可变的，我不能更改消息JSON，只需创建一个带有更改值的新消息，对吗？

Answer 1

如果您的订单更改了状态，则更改状态的流程应在主题中生成具有新状态的新消息。kafka streams应用程序可以对新消息做出反应，进行转换、聚合或类似操作，并在新主题中输出修改/聚合的消息。。。所以你需要一个Kafka制作人，当订单状态改变时，他会向订单主题发送一条消息。