我正在使用Confluent平台工作POC,并尝试在我的AWS帐户中连接Kinesis,以将数据发送到在Confluent平台上运行的Kafka(使用Docker Compose进行设置)。我已经使用了Confluent提供的AWS Kinesis连接器。我正在使用试用版的连接器,有效期为30天。
我已经从https://www.confluent.io/hub/confluentinc/kafka-connect-kinesis安装了KinesisSourceConnector插件
源连接器配置具有可用于AWS访问密钥ID和AWS密钥ID的凭据配置,但它没有用于AWS会话令牌的配置参数。由于我的AWS帐户只能使用STS访问,有什么方法可以设置吗?
我已尝试添加附加属性aws_access_key_id,但未成功。
错误说明-提供的凭据无效:请求中包含的安全令牌无效。(服务:AWSSecurityTokenService,状态码:403,错误码:InvalidClientTokenID,请求ID:d893039b-d4f3-4de3-95ef-ede233b0885c)
暂无答案!
目前还没有任何答案,快来回答吧!