我正在尝试将我的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/]
暂无答案!
目前还没有任何答案,快来回答吧!