Как установить Acks = all в файле свойств весенней загрузки

Question

Я хочу установить свойство acks = all для моего производителя в моем приложении весеннего облачного потока kafka.

Я пытался так:

spring.cloud.stream.kafka.binder.requiredAcks=all

и

spring.cloud.stream.kafka.streams.binder.configuration=all

и

spring.cloud.stream.kafka.streams.bindings.<channel>.producer.configuration.requiredAcks=all

К сожалению, замечание работает для меня.

Подскажите, пожалуйста, как мне установить свойства такого типа на уровне приложения или производителя / потребителя.

Answer 1

Приведенная ниже конфигурация используется только Binder Kafka (а не потоками Kafka).Он используется для установки свойства acks экземпляра производителя.

spring.cloud.stream.kafka.binder.requiredAcks

Для настройки экземпляра Kafka Streams свойства должны иметь префикс spring.cloud.stream.kafka.streams.binder ( Spring Cloud Stream Configuration) .

В KafkaStreams свойства производителей можно переопределить, добавив префикс ".producer" (см. Настройка приложения Streams ; поэтому, чтобы настроить подтверждения производителя, необходимо определить следующее свойство:

spring.cloud.stream.kafka.streams.binder.configuration.producer.acks=all

Обратите внимание, что если вы создаете приложение Kafka Streams с сохранением состояния, настоятельно рекомендуется включить семантику точно_конц .

Эту семантику можно настроить с помощью:

spring.cloud.stream.kafka.streams.binder.configuration.processing.guarantee=exactly-once