卡夫卡·萨加斯(Kafka Sagas) :blossom: Kafka-sagas是一个软件包,可让您使用与在之上构建的相似的语义。 使用Kafka-Sagas时,Kafka主题被视为传奇可以将动作分派到其中的流,并利用它们来发起传奇的特定动作。 用法 1.安装 npm install -- save kafka - sagas 2.确保已安装对等依赖项 npm install -- save kafkajs 什么是传奇? 传奇是一个生成器函数,它从主题接收有效负载并运行某些效果作为响应。 由传奇执行的效果都将在与发起动作相同的事务中执行。 例子: const topics = { BEGIN : 'BEGIN' , STARTED : 'STARTED' , COMPLETED : 'COMPLETED' , FAILED : 'FAILED' } ;