在Kafka中调度作业

628mspwn  于 2022-12-17  发布在  Apache
关注(0)|答案(1)|浏览(148)

我目前正在开发一个应用程序,它可以将任务作为定时器来调度。定时器可以在一周中的任何一天运行,用户可以对其进行配置。目前,它是通过bullqueue和redis来实现存储的。一旦定时器执行,它将执行一个事件并进一步处理业务逻辑。redis中可以有数千条队列消息。
我正在寻找取代redis与卡法,因为我已经阅读它很容易规模和保证没有消息丢失。
问题是。使用Kafa是个好主意吗?如果是,那么我们如何在Kafka中结合bullqueue来调度作业。我对Kafka是个新手,仍在试图理解我们如何在Kafka中调度作业,或者它是一个很好的架构设置。
我当前的应用程序设置是使用nestjs、nodejs

u3r8eeie

u3r8eeie1#

Kafka没有任何类似的内置特性,因此您需要将其与其他一些定时器/队列系统结合起来,以调度KafkaProducer操作。
类似地,Kafka Consumer通常总是在运行,不过您也可以定期启动/暂停它们。

相关问题