1 個回答
- 最新
- 最多得票
- 最多評論
1
If you are using IAM authentication and your access policy blocks topic operations like WriteData and ReadData then you get org.apache.kafka.common.errors.TopicAuthorizationException.
Also, permission boundaries and service control policies also block user attempting to connect to the cluster without the required authorization.
If you're using non-IAM authentication, then ensure that you have topic level access control lists (ACLs) that block operations.
You can run below command to list the ACLs that are applied on a topic:
bin/kafka-acls.sh --bootstrap-server $BOOTSTRAP:PORT --command-config adminclient-configs.conf –-list –-topic testtopic
Please refer https://repost.aws/knowledge-center/msk-cluster-connection-issues for more details.
已回答 2 年前
相關內容
- 已提問 3 個月前
