技術共有

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

背景

1. ユーザーのビジネス ニーズでは、プロデューサーの冪等性を有効にする必要があります。プロデューサーは、enable.idempotence = true という設定を追加しました。
2. ユーザーが使用するクラスターでは ACL 認証が有効になっています: SASL_PLAINTEXT/SCRAM-SHA-512
3. ユーザーがメッセージを生成すると、次のエラーが発生します: org.apache.kafka.common.errors.ClusterAuthorizationException: クラスターの承認に失敗しました。

解決する

サーバー構成

Kafka のソース コードを見ると、プロデューサー設定 (enable.idempotence) に次のような説明があることがわかりました。

'true'に設定すると、プロデューサーは各メッセージのコピーが1つだけストリームに書き込まれるようにします。 'false'の場合、ブローカーの障害などによりプロデューサーが再試行すると、再試行されたメッセージの重複がストリームに書き込まれる可能性があります。冪等性を有効にするには、

前の 次