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

jexiocij 于 2021-06-04 发布在 Kafka

关注(0)|答案(1)|浏览(876)

假设有Kafka主题。数据以json格式存储：

{
   "order_id": 1,
   "status": 1
}
``` `Status` 定义订单的状态（挂起-1，完成-2）。
完成后如何更改？
我知道kafka的主题是不可变的，我不能更改消息json，只需要创建一个带有更改值的新消息，对吗？

1条答案

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