diff --git a/spring-kafka-docs/src/main/antora/modules/ROOT/pages/retrytopic/dlt-strategies.adoc b/spring-kafka-docs/src/main/antora/modules/ROOT/pages/retrytopic/dlt-strategies.adoc
index 8741ed560e..cd2c3432f8 100644
--- a/spring-kafka-docs/src/main/antora/modules/ROOT/pages/retrytopic/dlt-strategies.adoc
+++ b/spring-kafka-docs/src/main/antora/modules/ROOT/pages/retrytopic/dlt-strategies.adoc
@@ -22,7 +22,7 @@ public void processMessage(MyPojo message) {
 }
 
 @DltHandler
-public void processMessage(MyPojo message) {
+public void processDltMessage(MyPojo message) {
     // ... message processing, persistence, etc
 }
 ----
diff --git a/spring-kafka-docs/src/main/antora/modules/ROOT/pages/retrytopic/features.adoc b/spring-kafka-docs/src/main/antora/modules/ROOT/pages/retrytopic/features.adoc
index 0e7d3d266a..ff97cb57bd 100644
--- a/spring-kafka-docs/src/main/antora/modules/ROOT/pages/retrytopic/features.adoc
+++ b/spring-kafka-docs/src/main/antora/modules/ROOT/pages/retrytopic/features.adoc
@@ -291,7 +291,6 @@ public RetryTopicConfiguration myRetryTopic(KafkaTemplate<String, MyPojo> templa
     return RetryTopicConfigurationBuilder
             .newInstance()
             .dltRoutingRules(Map.of("-deserialization", Set.of(DeserializationException.class)))
-            .create(kafkaOperations)
             .create(template);
 }
 ----
diff --git a/spring-kafka/src/main/java/org/springframework/kafka/listener/DeadLetterPublishingRecoverer.java b/spring-kafka/src/main/java/org/springframework/kafka/listener/DeadLetterPublishingRecoverer.java
index 9cbec59558..924e4ebceb 100644
--- a/spring-kafka/src/main/java/org/springframework/kafka/listener/DeadLetterPublishingRecoverer.java
+++ b/spring-kafka/src/main/java/org/springframework/kafka/listener/DeadLetterPublishingRecoverer.java
@@ -65,6 +65,7 @@
  * @author Gary Russell
  * @author Tomaz Fernandes
  * @author Watlas R
+ * @author Borahm Lee
  * @since 2.2
  *
  */
@@ -571,7 +572,7 @@ private void sendOrThrow(ProducerRecord<Object, Object> outRecord,
 
 	private void maybeThrow(ConsumerRecord<?, ?> record, Exception exception) {
 		String message = String.format("No destination returned for record %s and exception %s. " +
-				"failIfNoDestinationReturned: %s", KafkaUtils.format(record), exception,
+				"throwIfNoDestinationReturned: %s", KafkaUtils.format(record), exception,
 				this.throwIfNoDestinationReturned);
 		this.logger.warn(message);
 		if (this.throwIfNoDestinationReturned) {