Fix typo in ListenerContainerWithDlqAndRetryCustomizer example of kafka binder

2022-12-05 13:58:21 -05:00
parent 62e6a28d6d
commit 3c7c5230c6
1 changed files with 1 additions and 1 deletions
--- a/docs/src/main/asciidoc/kafka/kafka_overview.adoc
+++ b/docs/src/main/asciidoc/kafka/kafka_overview.adoc
@@ -905,7 +905,7 @@ ListenerContainerWithDlqAndRetryCustomizer cust(KafkaTemplate<?, ?> template) {
                @Nullable BackOff backOff) {

            if (destinationName.equals("topicWithLongTotalRetryConfig")) {
-                ConsumerRecordRecoverer dlpr = new DeadLetterPublishingRecoverer(template),
+                ConsumerRecordRecoverer dlpr = new DeadLetterPublishingRecoverer(template,
                        dlqDestinationResolver);
                container.setCommonErrorHandler(new DefaultErrorHandler(dlpr, backOff));
            }