ApsaraMQ for Kafka：開啟等冪功能，發送訊息報“Cluster authorization failed”錯誤

問題描述

開啟等冪功能後，發送訊息時用戶端報Cluster authorization failed錯誤。

問題原因

• 您使用了雲端儲存Topic，雲端儲存Topic不支援等冪功能。

• 如果使用Local Topic，並開啟了ACL功能，預設情況下，根據Kafka開源協議，Broker會判斷髮送者是否對Cluster叢集存在IDEMPOTENT_WRITE操作許可權。如果不存在該許可權，發送就會失敗。

解決方案

1. 雲端儲存類型Topic預設不支援等冪功能，可以關閉等冪功能。設定發送端enable.idempotence=false。

   說明

   ApsaraMQ for Kafka用戶端版本在V3.0及以上預設開啟等冪功能（即enable.idempotence=true）。

2. 為Cluster添加ACL相關許可權，在控制台SASL許可權管理頁面添加對相應使用者的Cluster資源類型的等冪寫入權限（IDEMPOTENT_WRITE）。更多資訊，請參見使用ACL功能進行存取控制。在添加許可權對話方塊中，指定要授權的使用者名稱，資源類型選擇Cluster，匹配方式選擇完全符合，操作類型勾選等冪寫。