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

Question

让我们假设有 Kafka 主题订单。数据以 JSON 格式存储：

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

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

完成后如何更改完成？

据我所知，Kafka 主题是不可变的，我无法更改消息 JSON，只需创建一个具有更改值的新消息，对吗？

标签： apache-kafkakafka-topic

Answer 1

如果您的订单更改状态，正在更改状态的进程应该在主题中生成一条带有新状态的新消息。kafka 流应用程序可以对新消息做出反应，进行转换聚合或类似的操作，并在新主题中输出修改/聚合的消息......所以你需要一个 kafka 生产者，当订单状态发生变化时，会向订单主题生成一条消息。