Debasish
Reputation: 1
How to set the property acks = all in properties file of a spring boot application
I have tried the following spring.kafka.producer.acks= - 1 And spring.cloud.stream.kafka.binder.requiredAcks= - 1
Both are not working and my MessageChannel.send() is still returning true with all the brokers down
Upvotes: 0
Views: 1487
Answers (1)
awgtek
Reputation: 1839
To set acks=all use:
spring.cloud.stream.kafka.binder.producer-properties.acks=all
If you want to set for a particular channel, override as follows:
spring.cloud.stream.kafka.bindings.mytopicchannel.producer.configuration.acks=all
Upvotes: 0
Related Questions
- Kafka Producer AWSSchemaRegistryConstants properties for YAML File
- how to set application properties to default kafka producer template without setting from kafka producer config bean
- Getting acks = -1 when I set acks to all in my Kafka producer
- Spring / Kafka - configuration properties priorities - application.properties, bean(ProducerFactory)
- Is it possible to set the 'acks' (acknowledgement) property other than in Producer configuration
- Spring boot kafka set ackOnError in application.properties
- Default values for ProducerConfigs in Spring-Boot Apache Kafka
- Where/How do i set acks for kafka
- How to apply spring.cloud.stream.kafka.bindings configuration property to all consumers
- How to set ack-mode in .properties/.yaml, when custom valueDeserializer is used?