Можно ли установить свойство «acks» (подтверждение), кроме как в конфигурации источника - PullRequest
1 голос
/ 19 сентября 2019

Нужна помощь в понимании свойства 'acks' в Kafka, которое есть в Конфигурации производителя.

Допустим, я пропустил передачу свойства 'acks' в классе продюсера.Тогда по умолчанию Кафка считает это 'acks = 0.Теперь предположим, что мне нужно иметь «acks = all», чтобы гарантировать доставку моего сообщения брокеру Kafka.Можно ли как-нибудь убедиться, что по умолчанию всегда есть «acks = all»? Может быть, в файле server.properties есть какие-либо настройки?

Я прочитал документацию Kafka https://kafka.apache.org/documentation/

1 Ответ

1 голос
/ 19 сентября 2019

С клиентом Java значение по умолчанию для acks равно 1, что означает, что подтверждение отправлено обратно производителю, как только брокер получил сообщение, см. http://kafka.apache.org/documentation/#producerconfigs

Эта конфигурация должна бытьустанавливается на всех клиентов производителя.Вы ничего не можете сделать с брокерами, чтобы изменить это.

...