Technologieaustausch

한어Русский языкEnglishFrançaisIndonesianSanskrit日本語DeutschPortuguêsΕλληνικάespañolItalianoSuomalainenLatina

Hintergrund

1. Für die geschäftlichen Anforderungen des Benutzers muss die Idempotenz des Produzenten aktiviert werden. Der Produzent hat die Konfiguration hinzugefügt: enable.idempotence = true
2. Für den vom Benutzer verwendeten Cluster ist die ACL-Authentifizierung aktiviert: SASL_PLAINTEXT/SCRAM-SHA-512
3. Wenn der Benutzer eine Nachricht erstellt, tritt ein Fehler auf: org.apache.kafka.common.errors.ClusterAuthorizationException: Cluster-Autorisierung fehlgeschlagen.

lösen

Serverkonfiguration

Als ich mir den Kafka-Quellcode ansah, stellte ich fest, dass die Produzentenkonfiguration (enable.idempotence) eine Beschreibung hat:

Wenn dieser Wert auf „true“ gesetzt ist, stellt der Produzent sicher, dass genau eine Kopie jeder Nachricht in den Stream geschrieben wird. Wenn dieser Wert auf „false“ gesetzt ist, können Wiederholungsversuche des Produzenten aufgrund von Broker-Fehlern usw. Duplikate der wiederholten Nachricht in den Stream schreiben. Beachten Sie, dass die Aktivierung der Idempotenz Folgendes erfordert:

Vorherige Nächste