[Kafka] Kafka-tuottaja ilmoittaa virheestä idempotenssin käyttöönoton jälkeen: Klusterin valtuutus epäonnistui._developdoc

[Kafka] Kafka-tuottaja ilmoitti virheestä idempotenssin käyttöönoton jälkeen: Klusterin valtuutus epäonnistui.

2024-07-11

Artikkelihakemisto

tausta
ratkaista
- Palvelimen määritykset
- ACL lisää valtuutuksen

tausta

Käyttäjän liiketoiminnan tarpeet edellyttävät, että tuottajan idempotenssi on käytössä. Tuottaja on lisännyt konfiguraation: enable.idempotence = true
Käyttäjän käyttämässä klusterissa on ACL-todennus käytössä: SASL_PLAINTEXT/SCRAM-SHA-512
Kun käyttäjä tuottaa viestin, tapahtuu virhe: org.apache.kafka.common.errors.ClusterAuthorizationException: Klusterin valtuutus epäonnistui.

ratkaista

Palvelimen määritykset

Tarkastellessani Kafka-lähdekoodia huomasin, että tuottajan kokoonpanossa (enable.idempotence) on kuvaus:

Kun asetuksena on "true", tuottaja varmistaa, että jokaisesta viestistä kirjoitetaan täsmälleen yksi kopio streamiin. Jos 'false', tuottaja yrittää uudelleen välittäjän vioista jne. johtuen, saattaa kirjoittaa uudelleen yritetyn viestin kaksoiskappaleita streamiin. Huomaa, että idempotenssin salliminen vaatii