ApsaraMQ for Kafka:Idempotence özelliğini etkinleştirdikten sonra mesaj gönderimi sırasında neden "Cluster authorization failed" hatası oluşur?

Sorun açıklaması

Idempotence özelliğini etkinleştirdiğinizde, mesaj gönderirken istemciye Cluster authorization failed hata iletisi döner.

Nedenler

• Cloud depolama kullanan bir konu kullanıyorsunuz. Bu tür konular idempotence özelliğini desteklemez.

• Küme üzerindeki IDEMPOTENT_WRITE izni mesaj göndericiye verilmemiştir. Yerel depolama kullanan bir konu kullanıyor ve ACL özelliğini etkinleştiriyorsanız ApsaraMQ for Kafka broker'ı, mesaj göndericinin küme üzerinde IDEMPOTENT_WRITE iznine sahip olup olmadığını otomatik olarak belirler. Mesaj göndericinin bu izni yoksa mesaj gönderilemez.

Çözümler

1. için cloud depolama konuları idempotence özelliğini desteklemez. Üreticide enable.idempotence=false ayarını yaparak özelliği devre dışı bırakın.

   Not

   Sürümü 3,0 veya üzeri olan bir ApsaraMQ for Kafka istemcisi için idempotence özelliği otomatik olarak etkinleştirilir. enable.idempotence parametresi otomatik olarak true değerine ayarlanır.

2. Küme için gerekli ACL izinlerini verin. Konsoldaki SASL izin yönetimi sayfasında Add Permission iletişim kutusunu kullanarak ayarları yapılandırın: kullanıcıyı belirtin, Resource Type alanını Cluster olarak ayarlayın, Matching Method alanını Exact Match olarak seçin ve Operation Type için IDEMPOTENT_WRITE seçeneğini işaretleyin. Daha fazla bilgi için bkz. Erişim kontrolü için ACL kullanma.