0

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

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

Status定义订单状态(待定 - 1,已完成 - 2)。

完成后如何更改完成?

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

4

1 回答 1

0

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

于 2020-07-05T07:39:04.880 回答