Получение acks = -1, когда я устанавливаю acks для всех в моем продюсере Kafka

Я установил следующее свойство для своего продюсера Kafka:

properties.setProperty(ProducerConfig.ACKS_CONFIG, "all");

Когда я запускаю свое приложение, я вижу acks = -1 в ProducerConfig values. Почему это?


person runnerpaul    schedule 17.10.2020    source источник


Ответы (1)


Для конфигурации производителя acks свойство -1 равно all.

Конфигурация производителя из документации Kafka:

acks = all Это означает, что лидер будет ждать, пока полный набор синхронизированных реплик подтвердит запись. Это гарантирует, что запись не будет потеряна, пока остается жива хотя бы одна синхронизированная реплика. Это самая надежная доступная гарантия. Это эквивалентно параметру acks = -1.

person Ofek Hod    schedule 17.10.2020