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

Question

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

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

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

完成后怎么改成on completed？

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

Answer 1

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

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

How to update data in Kafka/Kafka stream?

apache-kafka

kafka-topic