[Kafka] Produser Kafka melaporkan kesalahan setelah mengaktifkan idempotensi: Otorisasi cluster gagal._developdoc

[Kafka] Produser Kafka melaporkan kesalahan setelah mengaktifkan idempotensi: Otorisasi cluster gagal.

2024-07-11

Direktori artikel

latar belakang
menyelesaikan
- Konfigurasi server
- ACL menambahkan otorisasi

latar belakang

Kebutuhan bisnis pengguna mengharuskan idempotensi produsen diaktifkan. Produser telah menambahkan konfigurasi: aktifkan.idempotensi = true
Klaster yang digunakan oleh pengguna telah mengaktifkan autentikasi ACL: SASL_PLAINTEXT/SCRAM-SHA-512
Saat pengguna membuat pesan, terjadi kesalahan: org.apache.kafka.common.errors.ClusterAuthorizationException: Otorisasi cluster gagal.

menyelesaikan

Konfigurasi server

Melihat kode sumber Kafka, saya menemukan bahwa konfigurasi produser (enable.idempotence) memiliki deskripsi:

Bila diatur ke 'true', produser akan memastikan bahwa tepat satu salinan dari setiap pesan ditulis dalam aliran. Jika 'false', produser mencoba lagi karena kegagalan broker, dll., dapat menulis duplikat dari pesan yang dicoba lagi dalam aliran. Perhatikan bahwa mengaktifkan idempotensi memerlukan

Profil pribadi

Ia telah mengabdikan dirinya untuk meneliti teknologi selama lebih dari 30 tahun, dan mahir dalam berbagai bahasa seperti java, linux, javascript, php, css, dll. Ia telah memberikan banyak kontribusi di bidang open source stasiun dokumentasi pengembang untuk berbagi beberapa masalah dalam pengembangan teknologi untuk referensi di masa mendatang

informasi kontak saya

Surat[email protected]