ApsaraMQ for Kafka:¿Por qué se reporta el error "Cluster authorization failed" durante el envío de mensajes después de habilitar la función de idempotencia?

Descripción del problema

Después de habilitar la función de idempotencia, el cliente recibe el mensaje de error Cluster authorization failed cuando se envían mensajes.

Causas

• Usa un tema con almacenamiento en la nube. Estos temas no admiten la función de idempotencia.

• El remitente del mensaje no tiene concedido el permiso IDEMPOTENT_WRITE en el clúster. Si utiliza un tema con almacenamiento local y habilita la función de ACL, el broker de ApsaraMQ for Kafka determina automáticamente si el remitente tiene el permiso IDEMPOTENT_WRITE en el clúster. Si no lo tiene, el mensaje no se envía.

Soluciones

1. Los temas de almacenamiento en la nube para no admiten la función de idempotencia. Deshabilite la función; para ello, establezca enable.idempotence=false en el productor.

   Nota

   La función de idempotencia se habilita automáticamente en un cliente de ApsaraMQ for Kafka cuya versión es 3.0 o posterior. El parámetro enable.idempotence se establece automáticamente en true.

2. Conceda los permisos de ACL obligatorios para el clúster. En la página de administración de permisos SASL de la consola, use el cuadro de diálogo Add Permission y configure los valores: especifique el usuario, establezca Resource Type en Cluster y Matching Method en Exact Match, y seleccione IDEMPOTENT_WRITE para Operation Type. Para obtener más información, consulte Use ACL for access control.