ApsaraMQ for Kafka：Mengapa kesalahan "Cluster authorization failed" dilaporkan saat pengiriman pesan setelah saya mengaktifkan fitur idempotensi?

Deskripsi masalah

Setelah mengaktifkan fitur idempotensi, klien menerima pesan kesalahan Cluster authorization failed saat mencoba mengirim pesan.

Penyebab

• Anda menggunakan topik dengan penyimpanan cloud, yang tidak mendukung fitur idempotensi.

• Pengirim pesan tidak memiliki izin IDEMPOTENT_WRITE pada kluster. Jika Anda menggunakan topik dengan penyimpanan lokal dan mengaktifkan fitur ACL, broker ApsaraMQ for Kafka secara otomatis memverifikasi apakah pengirim memiliki izin IDEMPOTENT_WRITE. Jika izin ini tidak diberikan, pengiriman pesan akan gagal.

Solusi

1. Jika Anda menggunakan topik dengan penyimpanan cloud, nonaktifkan fitur idempotensi dengan mengatur parameter enable.idempotence menjadi false di klien.

   Catatan

   Fitur idempotensi secara otomatis diaktifkan untuk klien ApsaraMQ for Kafka versi 3.0 atau lebih baru. Parameter enable.idempotence secara otomatis diatur menjadi true.

2. Berikan izin IDEMPOTENT_WRITE pada kluster kepada pengguna yang sesuai melalui tab Manage SASL User Permissions di konsol ApsaraMQ for Kafka. Untuk informasi lebih lanjut, lihat Gunakan fitur ACL untuk kontrol akses.