Skip to content

Commit

Permalink
Removing deprecated setAckOnError method call (#1082)
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 #1079
  • Loading branch information
sobychacko committed May 24, 2021
1 parent cb42e80 commit 5f4e3ee
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 5f4e3ee

Please sign in to comment.