diff --git a/binders/kafka-binder/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/properties/KafkaBinderConfigurationProperties.java b/binders/kafka-binder/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/properties/KafkaBinderConfigurationProperties.java
index e0650e1eb0..aba61d5340 100644
--- a/binders/kafka-binder/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/properties/KafkaBinderConfigurationProperties.java
+++ b/binders/kafka-binder/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/properties/KafkaBinderConfigurationProperties.java
@@ -110,7 +110,7 @@ public class KafkaBinderConfigurationProperties {
 
 	private boolean considerDownWhenAnyPartitionHasNoLeader = true;
 
-	private String requiredAcks = "1";
+	private String requiredAcks = "all";
 
 	private short replicationFactor = -1;
 
diff --git a/binders/kafka-binder/spring-cloud-stream-binder-kafka-core/src/test/java/org/springframework/cloud/stream/binder/kafka/properties/KafkaBinderConfigurationPropertiesTest.java b/binders/kafka-binder/spring-cloud-stream-binder-kafka-core/src/test/java/org/springframework/cloud/stream/binder/kafka/properties/KafkaBinderConfigurationPropertiesTest.java
index bfd16aba6d..04634a159f 100644
--- a/binders/kafka-binder/spring-cloud-stream-binder-kafka-core/src/test/java/org/springframework/cloud/stream/binder/kafka/properties/KafkaBinderConfigurationPropertiesTest.java
+++ b/binders/kafka-binder/spring-cloud-stream-binder-kafka-core/src/test/java/org/springframework/cloud/stream/binder/kafka/properties/KafkaBinderConfigurationPropertiesTest.java
@@ -37,6 +37,16 @@
 
 class KafkaBinderConfigurationPropertiesTest {
 
+	@Test
+	@SuppressWarnings("unchecked")
+	void defaultRequiredAcksIsAll() {
+		KafkaProperties kafkaProperties = new KafkaProperties();
+		KafkaBinderConfigurationProperties kafkaBinderConfigurationProperties =
+				new KafkaBinderConfigurationProperties(kafkaProperties, mock(ObjectProvider.class));
+
+		assertThat(kafkaBinderConfigurationProperties.getRequiredAcks()).isEqualTo("all");
+	}
+
 	@Test
 	@SuppressWarnings("unchecked")
 	void mergedConsumerConfigurationFiltersGroupIdFromKafkaProperties() {
diff --git a/docs/modules/ROOT/pages/kafka/kafka-binder/config-options.adoc b/docs/modules/ROOT/pages/kafka/kafka-binder/config-options.adoc
index c2e87266b9..d59d389b57 100644
--- a/docs/modules/ROOT/pages/kafka/kafka-binder/config-options.adoc
+++ b/docs/modules/ROOT/pages/kafka/kafka-binder/config-options.adoc
@@ -43,7 +43,7 @@ spring.cloud.stream.kafka.binder.requiredAcks::
 The number of required acks on the broker.
 See the Kafka documentation for the producer `acks` property.
 +
-Default: `1`.
+Default: `all`.
 spring.cloud.stream.kafka.binder.minPartitionCount::
 Effective only if `autoCreateTopics` or `autoAddPartitions` is set.
 The global minimum number of partitions that the binder configures on topics on which it produces or consumes data.
diff --git a/docs/modules/ROOT/pages/kafka/kafka_overview.adoc b/docs/modules/ROOT/pages/kafka/kafka_overview.adoc
index f812b3a490..63b72cabdb 100644
--- a/docs/modules/ROOT/pages/kafka/kafka_overview.adoc
+++ b/docs/modules/ROOT/pages/kafka/kafka_overview.adoc
@@ -83,7 +83,7 @@ spring.cloud.stream.kafka.binder.requiredAcks::
 The number of required acks on the broker.
 See the Kafka documentation for the producer `acks` property.
 +
-Default: `1`.
+Default: `all`.
 spring.cloud.stream.kafka.binder.minPartitionCount::
 Effective only if `autoCreateTopics` or `autoAddPartitions` is set.
 The global minimum number of partitions that the binder configures on topics on which it produces or consumes data.