增加IAM授权策略,给予该实例访问主题的权限。
IAM策略示例:
{
"Version": "2012-10-17",
"Statement": [
{
"Effect": "Allow",
"Principal": {
"Service": "kafka.amazonaws.com"
},
"Action": "sts:AssumeRole"
}
]
}
示例代码:
import boto3
client = boto3.client('kafka')
response = client.update_cluster_configuration(
ClusterArn='arn:aws:kafka:us-west-2:111111111111:cluster/test',
ConfigurationInfo={
'Arn': 'arn:aws:iam::111111111111:policy/TestKafkaPolicy',
'Revision': '1'
}
)
需要注意的是,在以上代码中:
ClusterArn
需要替换为您的ClusterArn。Arn
需要替换为您给该实例赋予权限的IAM策略ARN。Revision
需要替换为这个IAM策略的版本。