lambda sink connector在我的ubuntuec2示例中没有选择aws\u access\u key\u id、aws\u secret\u access\u key值

fdx2calv  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(228)

我正在尝试将我的kafka主题数据推送到带有nordstrom lambda sink connector的aws lambda函数中,在将aws凭证设置为环境变量之后,连接器仍然显示以下错误
将aws\u access\u key\u id、aws\u secret\u access\u key值导出为

export AWS_ACCESS_KEY_ID=XXXXXXXXXX 
export AWS_SECRET_ACCESS_KEY=XXXXXXXXXXXXXXXXXX

my connector.json配置:

{
    "name": "example-lambda-connector",
    "config": {
      "tasks.max": "1",
      "connector.class": "com.nordstrom.kafka.connect.lambda.LambdaSinkConnector",
      "topics": "example-stream",
      "key.converter": "org.apache.kafka.connect.storage.StringConverter",
      "value.converter": "org.apache.kafka.connect.storage.StringConverter",
      "aws.region": "ap-south-1",
      "aws.lambda.function.arn": "arn:aws:lambda:ap-south-1:111111111:function:example-function",
      "aws.lambda.invocation.timeout.ms": "60000",
      "aws.lambda.invocation.mode": "SYNC",
      "aws.lambda.batch.enabled": "false"
      }
     }

获取以下错误:
原因:java.util.concurrent.executionexception:com.amazonaws.sdkclientexception:无法从链中的任何提供程序加载aws凭据:[environmentvariablecredentialsprovider:无法从环境变量(aws\ U access\ U key\ id(或aws\ U access\ U key)和aws\ U secret\ U key(或aws\ U secret\ U access\ U key))加载aws凭据,systempropertiescredentialsprovider:无法从java系统属性(aws.accesskeyid和aws.secretkey)、com.amazonaws.auth.profile加载aws凭据。profilecredentialsprovider@503af16e:配置文件不能为null,webidentitytokencredentialsprovider:必须为rolearn和rolesessionname指定一个值,亚马逊网站。ec2containercredentialsproviderwrapper@76a59f2c:在中找不到请求的元数据http://169.254.169.254/latest/meta-data/iam/security-credentials/]

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题