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年前
