背景:首先MSK就是配置一个AWS的托管 kafka,创建完成之后就交给开发进行使用,开发通常是从代码中,编写AWS的access_key 和secret_key进行调用。


但是开发在进行调用的时候,一直报错连接失败,其实问题很简单!

一、首先你要保证你的Key拥有足够的权限,在IAM账户配置:

配置一个AmazonMSKFullAccess 最为方便。


二、观察你的MSK集群是不是启用了加密:

如果启用了加密,代码在调用的时候,必须拥有KMS的权限 :

这个权限保证在传输中的加密和解密,如果没有同样会报错。

加上这两个权限之后,搞定。 

点赞(0) 打赏

评论列表 共有 0 条评论

暂无评论

微信公众账号

微信扫一扫加关注

发表
评论
返回
顶部