diff --git a/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaMessageChannelBinder.java b/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaMessageChannelBinder.java
index 730bf412a..a42ef4680 100644
--- a/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaMessageChannelBinder.java
+++ b/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaMessageChannelBinder.java
@@ -709,11 +709,6 @@ public class KafkaMessageChannelBinder extends
 				if (!extendedConsumerProperties.getExtension().isAutoCommitOffset()) {
 					messageListenerContainer.getContainerProperties()
 							.setAckMode(ContainerProperties.AckMode.MANUAL);
-					messageListenerContainer.getContainerProperties().setAckOnError(false);
-				}
-				else {
-					messageListenerContainer.getContainerProperties()
-							.setAckOnError(isAutoCommitOnError(extendedConsumerProperties));
 				}
 			}
 		}