File tree 2 files changed +5
-5
lines changed
spring-kafka/src/main/java/org/springframework/kafka/retrytopic
spring-kafka-docs/src/main/asciidoc
2 files changed +5
-5
lines changed Original file line number Diff line number Diff line change @@ -840,7 +840,7 @@ The framework provides a few strategies for working with DLTs. You can provide a
840
840
841
841
===== Dlt Processing Method
842
842
843
- You can specify the method used to process the Dlt for the topic, as well as the behavior if that processing fails.
843
+ You can specify the method used to process the DLT for the topic, as well as the behavior if that processing fails.
844
844
845
845
To do that you can use the `@DltHandler` annotation in a method of the class with the `@RetryableTopic` annotation(s).
846
846
Note that the same method will be used for all the `@RetryableTopic` annotated methods within that class.
@@ -870,7 +870,7 @@ The DLT handler method can also be provided through the RetryTopicConfigurationB
870
870
public RetryTopicConfiguration myRetryTopic(KafkaTemplate<Integer, MyPojo> template) {
871
871
return RetryTopicConfigurationBuilder
872
872
.newInstance()
873
- .dltProcessor ("myCustomDltProcessor", "processDltMessage")
873
+ .dltHandlerMethod ("myCustomDltProcessor", "processDltMessage")
874
874
.create(template);
875
875
}
876
876
@@ -923,7 +923,7 @@ public void processMessage(MyPojo message) {
923
923
public RetryTopicConfiguration myRetryTopic(KafkaTemplate<Integer, MyPojo> template) {
924
924
return RetryTopicConfigurationBuilder
925
925
.newInstance()
926
- .dltProcessor(MyCustomDltProcessor.class , "processDltMessage")
926
+ .dltHandlerMethod("myCustomDltProcessor" , "processDltMessage")
927
927
.doNotRetryOnDltFailure()
928
928
.create(template);
929
929
}
Original file line number Diff line number Diff line change 1
1
/*
2
- * Copyright 2018-2022 the original author or authors.
2
+ * Copyright 2018-2023 the original author or authors.
3
3
*
4
4
* Licensed under the Apache License, Version 2.0 (the "License");
5
5
* you may not use this file except in compliance with the License.
178
178
* public RetryTopicConfiguration otherRetryTopic(KafkaTemplate<Integer, MyPojo> template) {
179
179
* return RetryTopicConfigurationBuilder
180
180
* .newInstance()
181
- * .dltProcessor(MyCustomDltProcessor.class , "processDltMessage")
181
+ * .dltHandlerMethod("myCustomDltProcessor" , "processDltMessage")
182
182
* .create(template);
183
183
* }</code>
184
184
*
You can’t perform that action at this time.
0 commit comments