Compartir tecnología

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

fondo

1. Las necesidades comerciales del usuario requieren que se habilite la idempotencia del productor. El productor ha agregado la configuración: enable.idempotence = true.
2. El clúster utilizado por el usuario tiene habilitada la autenticación ACL: SASL_PLAINTEXT/SCRAM-SHA-512
3. Cuando el usuario genera un mensaje, se produce un error: org.apache.kafka.common.errors.ClusterAuthorizationException: Error en la autorización del clúster.

resolver

Configuración del servidor

Al mirar el código fuente de Kafka, encontré que la configuración del productor (enable.idempotence) tiene una descripción:

Cuando se establece en "true", el productor se asegurará de que se escriba exactamente una copia de cada mensaje en la secuencia. Si es "false", los reintentos del productor debido a fallas del agente, etc., pueden escribir duplicados del mensaje reintentado en la secuencia. Tenga en cuenta que para habilitar la idempotencia se requiere

Anterior Próximo