Update DLT log message and docs (#3656)

spring-projects · Dec 3, 2024 · eca3750 · eca3750
1 parent 3f72bb3
commit eca3750
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/...ng-kafka-docs/src/main/antora/modules/ROOT/pages/retrytopic/dlt-strategies.adoc b/...ng-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
@@ -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/...kafka/src/main/java/org/springframework/kafka/listener/DeadLetterPublishingRecoverer.java b/...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) {