问题描述
我想将Lambda函数附加到AWS MSK Kafka集群中的主题,但是根据我在AWS文档中了解的内容,这还不可能。
所以我想我可以有一个Lambda函数,该间隔将间隔运行,使用CloudWatch事件每分钟触发一次。
另一种选择是运行一个小的ec2单元来运行客户端使用者。
我不确定这是否是最便宜的解决方案。那么,我们可以使用哪种最具成本效益的解决方案来实现像Lambda到SQS连接器这样的解决方案呢?
解决方法
您现在可以将MSK主题用作AWS lambda的事件源(截至上周)!每次发出亚马逊发布声明时,此服务都不收取额外费用!
创建lambda函数后,可以将MSK添加为触发器。确保您附加了适当的策略(如下面引用的文章所述)。
以下是一些相关资源。
https://aws.amazon.com/blogs/compute/using-amazon-msk-as-an-event-source-for-aws-lambda/ https://docs.aws.amazon.com/lambda/latest/dg/with-msk.html