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

Question

Я пробовал следующие spring.kafka.producer.acks= - 1 и spring.cloud.stream.kafka.binder.requiredAcks= - 1

Оба не работают, и мой MessageChannel.send() по-прежнему возвращает истину со всеми брокерами.

Answer 1

Чтобы установить acks=all, используйте:

      spring.cloud.stream.kafka.binder.producer-properties.acks=all

Если вы хотите установить для определенного канала, переопределите следующим образом:

      spring.cloud.stream.kafka.bindings.mytopicchannel.producer.configuration.acks=all

Ссылка: https://cloud.spring.io/spring-cloud-stream-binder-kafka/spring-cloud-stream-binder-kafka.html#_configuration_options