Skip to content

Commit

Permalink
Removing deprecated setAckOnError method call
Browse files Browse the repository at this point in the history
Going forward, binder will use the default ack on error settings
in Spring Kafka, which is true by default. If the applicaitons
need to change this behavior, then a custom error handler must
be provided through ListenerContainerCustomizer.

Resolves spring-cloud#1079
  • Loading branch information
sobychacko committed May 24, 2021
1 parent cb42e80 commit cf41f24
Showing 1 changed file with 0 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -709,11 +709,6 @@ else if (applicationContext != null) {
if (!extendedConsumerProperties.getExtension().isAutoCommitOffset()) {
messageListenerContainer.getContainerProperties()
.setAckMode(ContainerProperties.AckMode.MANUAL);
messageListenerContainer.getContainerProperties().setAckOnError(false);
}
else {
messageListenerContainer.getContainerProperties()
.setAckOnError(isAutoCommitOnError(extendedConsumerProperties));
}
}
}
Expand Down

0 comments on commit cf41f24

Please sign in to comment.