时间戳

首页 > 解决方案 > 自我管理的 JAAS 启用 Apache Kafka + AWS Lambda

amazon-web-services - 自我管理的 JAAS 启用 Apache Kafka + AWS Lambda

问题描述

我一直在尝试使用 Self managed jaas enable apache kafka（在 EC2 实例中部署/运行）触发我的 lambda。我的 jaas 启用 kafka 部署/运行的资源 Lambda 和 EC2 实例都在 vpc 网络下，并且具有相同的安全组，它们都具有相同的内联策略，如下所示：

{
"Version": "2012-10-17",
"Statement": [
    {
        "Effect": "Allow",
        "Action": [
            "ec2:CreateNetworkInterface",
            "ec2:DescribeNetworkInterfaces",
            "ec2:DescribeVpcs",
            "ec2:DeleteNetworkInterface",
            "ec2:DescribeSubnets",
            "ec2:DescribeSecurityGroups",
            "logs:CreateLogGroup",
            "logs:CreateLogStream",
            "logs:PutLogEvents"
        ],
        "Resource": " arn:aws:ec2:<REGION>:<ACCOUNT_ID>:instance/<instance-id>"
    }
]
}

使用以下步骤将触发器添加到 lambda ：

  1. 在 Lambda 函数中，选择配置选项卡。在设计器面板中，选择添加触发器。

  2. 在下拉列表中，选择 Apache Kafka：

  3. 对于 Bootstrap 服务器，添加两个实例私有 IPv4 DNS 地址中的每一个，并附加端口 9092。

  4. 对于主题名称，输入在 kafka 中创建的主题。

  5. 对于首选批量大小，插入分区计数和起始位置值设置为最新。

  6. 对于 VPC、VPC 子网、VPC 安全组保持与 Ec2 实例相同。

选择添加。

但在完成这些操作后，我仍然收到错误作为 最后处理结果：问题：连接错误。请检查您的事件源连接配置。

标签： amazon-web-servicesapache-kafka

解决方案

推荐阅读