0

我有一个应用程序使用 AWS SQS 和 Lambda 来处理推送到队列上的消息。Lambda 继续轮询队列,当出现新消息时,它会处理该消息。

对于这种情况,是否可以在 AWS 上将 SQS 替换为 Kafka。换句话说,我们可以使用 Kafka 作为这个用例的队列吗?

4

1 回答 1

1

你绝对可以。查看适用于 Apache Kafka (Amazon MSK) 的 AWS Amazon Managed Streaming 。它是 Apache Kafka 的托管服务。

至于 lambda 触发器,不幸的是它不是内置触发器。您可以使用定期触发的 lambda 函数轻松复制行为,该函数检查消息是否可见,然后调用将处理消息或直接处理消息的函数。对于某些方向,您可以参考这个官方指南,它设置了一个类似的管道,但适用于AWS MQ

于 2020-07-16T12:49:14.157 回答