Partage de technologie

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

arrière-plan

1. Les besoins métier des utilisateurs nécessitent que l'idempotence du producteur soit activée. Le producteur a ajouté la configuration : activate.idempotence = true.
2. Le cluster utilisé par l'utilisateur a l'authentification ACL activée : SASL_PLAINTEXT/SCRAM-SHA-512
3. Lorsque l'utilisateur produit un message, une erreur se produit : org.apache.kafka.common.errors.ClusterAuthorizationException : l'autorisation du cluster a échoué.

résoudre

Configuration du serveur

En regardant le code source de Kafka, j'ai trouvé que la configuration du producteur (enable.idempotence) a une description :

Lorsque la valeur est définie sur « true », le producteur s'assurera qu'une seule copie de chaque message est écrite dans le flux. Si la valeur est définie sur « false », les nouvelles tentatives du producteur en raison d'échecs du courtier, etc., peuvent écrire des doublons du message réessayé dans le flux. Notez que l'activation de l'idempotence nécessite

Précédent Suivant