Я установил следующее свойство для своего продюсера Kafka:
properties.setProperty(ProducerConfig.ACKS_CONFIG, "all");
Когда я запускаю свое приложение, я вижу acks = -1
в ProducerConfig values
. Почему это?
Я установил следующее свойство для своего продюсера Kafka:
properties.setProperty(ProducerConfig.ACKS_CONFIG, "all");
Когда я запускаю свое приложение, я вижу acks = -1
в ProducerConfig values
. Почему это?
Для конфигурации производителя acks
свойство -1
равно all
.
Конфигурация производителя из документации Kafka:
acks = all Это означает, что лидер будет ждать, пока полный набор синхронизированных реплик подтвердит запись. Это гарантирует, что запись не будет потеряна, пока остается жива хотя бы одна синхронизированная реплика. Это самая надежная доступная гарантия. Это эквивалентно параметру acks = -1.