기술나눔

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

배경

1. 사용자 비즈니스 요구 사항에 따라 생산자의 멱등성을 활성화해야 합니다. 생산자는 다음 구성을 추가했습니다.
2. 사용자가 사용하는 클러스터에 ACL 인증이 활성화되어 있습니다: SASL_PLAINTEXT/SCRAM-SHA-512
3. 사용자가 메시지를 생성하면 org.apache.kafka.common.errors.ClusterAuthorizationException: 클러스터 인증에 실패했습니다.라는 오류가 발생합니다.

해결하다

서버 구성

Kafka 소스 코드를 살펴보면 생산자 구성(enable.idempotence)에 다음과 같은 설명이 있는 것을 발견했습니다.

'true'로 설정하면 프로듀서는 각 메시지의 사본이 정확히 한 개만 스트림에 기록되도록 합니다. 'false'로 설정하면 프로듀서가 브로커 오류 등으로 인해 재시도하여 스트림에 재시도된 메시지의 중복을 쓸 수 있습니다. 멱등성을 활성화하려면 다음이 필요합니다.

이전의 다음