Skip to content

Commit eca3750

Browse files
authored
Update DLT log message and docs (spring-projects#3656)
1 parent 3f72bb3 commit eca3750

File tree

3 files changed

+3
-3
lines changed

3 files changed

+3
-3
lines changed

spring-kafka-docs/src/main/antora/modules/ROOT/pages/retrytopic/dlt-strategies.adoc

+1-1
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@ public void processMessage(MyPojo message) {
2222
}
2323
2424
@DltHandler
25-
public void processMessage(MyPojo message) {
25+
public void processDltMessage(MyPojo message) {
2626
// ... message processing, persistence, etc
2727
}
2828
----

spring-kafka-docs/src/main/antora/modules/ROOT/pages/retrytopic/features.adoc

-1
Original file line numberDiff line numberDiff line change
@@ -291,7 +291,6 @@ public RetryTopicConfiguration myRetryTopic(KafkaTemplate<String, MyPojo> templa
291291
return RetryTopicConfigurationBuilder
292292
.newInstance()
293293
.dltRoutingRules(Map.of("-deserialization", Set.of(DeserializationException.class)))
294-
.create(kafkaOperations)
295294
.create(template);
296295
}
297296
----

spring-kafka/src/main/java/org/springframework/kafka/listener/DeadLetterPublishingRecoverer.java

+2-1
Original file line numberDiff line numberDiff line change
@@ -65,6 +65,7 @@
6565
* @author Gary Russell
6666
* @author Tomaz Fernandes
6767
* @author Watlas R
68+
* @author Borahm Lee
6869
* @since 2.2
6970
*
7071
*/
@@ -571,7 +572,7 @@ private void sendOrThrow(ProducerRecord<Object, Object> outRecord,
571572

572573
private void maybeThrow(ConsumerRecord<?, ?> record, Exception exception) {
573574
String message = String.format("No destination returned for record %s and exception %s. " +
574-
"failIfNoDestinationReturned: %s", KafkaUtils.format(record), exception,
575+
"throwIfNoDestinationReturned: %s", KafkaUtils.format(record), exception,
575576
this.throwIfNoDestinationReturned);
576577
this.logger.warn(message);
577578
if (this.throwIfNoDestinationReturned) {

0 commit comments

Comments
 (0)