1 Respuesta
- Más nuevo
- Más votos
- Más comentarios
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.
respondido hace 2 años
Contenido relevante
- preguntada hace 4 meses
- preguntada hace 17 días
- preguntada hace 5 meses
- preguntada hace 17 días
- OFICIAL DE AWSActualizada hace 4 años
