我有一个应用程序使用 AWS SQS 和 Lambda 来处理推送到队列上的消息。Lambda 继续轮询队列,当出现新消息时,它会处理该消息。
对于这种情况,是否可以在 AWS 上将 SQS 替换为 Kafka。换句话说,我们可以使用 Kafka 作为这个用例的队列吗?
我有一个应用程序使用 AWS SQS 和 Lambda 来处理推送到队列上的消息。Lambda 继续轮询队列,当出现新消息时,它会处理该消息。
对于这种情况,是否可以在 AWS 上将 SQS 替换为 Kafka。换句话说,我们可以使用 Kafka 作为这个用例的队列吗?
你绝对可以。查看适用于 Apache Kafka (Amazon MSK) 的 AWS Amazon Managed Streaming 。它是 Apache Kafka 的托管服务。
至于 lambda 触发器,不幸的是它不是内置触发器。您可以使用定期触发的 lambda 函数轻松复制行为,该函数检查消息是否可见,然后调用将处理消息或直接处理消息的函数。对于某些方向,您可以参考这个官方指南,它设置了一个类似的管道,但适用于AWS MQ。