我正在尝试从客户的MSK集群中使用Kafka事件。
我不能让它运行。我得到间歇性错误:问题:连接错误。请检查您的事件源连接配置。如果您的事件源位于VPC中,请尝试使用相同的VPC、子网和安全组设置设置设置新的Lambda函数或EC2示例有时“最后处理结果”显示:“好的”
我无法从文件中理解建议。有人有这方面的经验吗?
我有:
- 在我们的帐户中创建了VPC
- 我们的客户已创建到我们的VPC的对等连接,我已接受此连接
- 创建了一个简单的lambda处理程序
- 添加了一个自管理的Kafka事件触发器,具有以下属性:
- 客户的经纪人地址
- 商定主题
- 已输入SASL-SCRAM凭据
- 将VPC设置为我的VPC、子网和安全组(我无法查看/访问客户的对等VPC)
- 将lambda处理程序的VPC设置为我的VPC
- 在我们的VPC中为Lambda、STS和SecretManager创建端点
1条答案
按热度按时间mkshixfv1#
您的客户应在其VPC中运行Lambda。
在对等VPC之后,请确保您还configured routing。
为MSK安全组添加入站规则,允许远程私有网络访问。
测试您的连接:要求客户telnet到端口9096