diff --git a/binders/kafka-binder/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/ListenerContainerWithDlqAndRetryCustomizer.java b/binders/kafka-binder/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/ListenerContainerWithDlqAndRetryCustomizer.java index 567ac6441..ed453c097 100644 --- a/binders/kafka-binder/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/ListenerContainerWithDlqAndRetryCustomizer.java +++ b/binders/kafka-binder/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/ListenerContainerWithDlqAndRetryCustomizer.java @@ -62,7 +62,7 @@ public interface ListenerContainerWithDlqAndRetryCustomizer * {@link #configure(AbstractMessageListenerContainer, String, String, BiFunction, BackOff)}. * @param destinationName the destination name. * @param group the group. - * @return true to disable retrie in the binding + * @return false to disable retries and DLQ in the binding */ default boolean retryAndDlqInBinding(String destinationName, String group) { return true; diff --git a/docs/src/main/asciidoc/kafka/kafka_overview.adoc b/docs/src/main/asciidoc/kafka/kafka_overview.adoc index 46eacfdb8..dca41b052 100644 --- a/docs/src/main/asciidoc/kafka/kafka_overview.adoc +++ b/docs/src/main/asciidoc/kafka/kafka_overview.adoc @@ -894,7 +894,7 @@ void configure(AbstractMessageListenerContainer container, String destinat * {@link #configure(AbstractMessageListenerContainer, String, String, BiFunction, BackOff)}. * @param destinationName the destination name. * @param group the group. - * @return true to disable retrie in the binding + * @return false to disable retries and DLQ in the binding */ default boolean retryAndDlqInBinding(String destinationName, String group) { return true;