Skip to content

Commit f83cb26

Browse files
authored
Replace deprecated FixedDelay in docs (#3912)
* Replace `FixedDelayStrategy` to `SameIntervalTopicReuseStrategy` in docs * `useSingleTopicForFixedDelays` -> `useSingleTopicForSameIntervals` Signed-off-by: Seonghyeon Cho <[email protected]> **Auto-cherry-pick to `3.3.x` & `3.2.x`**
1 parent 12bc85d commit f83cb26

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -79,7 +79,7 @@ NOTE: The previous `FixedDelayStrategy` is now deprecated, and can be replaced b
7979

8080
[source, java]
8181
----
82-
@RetryableTopic(backoff = @Backoff(2_000), fixedDelayTopicStrategy = FixedDelayStrategy.SINGLE_TOPIC)
82+
@RetryableTopic(backoff = @Backoff(2_000), sameIntervalTopicReuseStrategy = SameIntervalTopicReuseStrategy.SINGLE_TOPIC)
8383
@KafkaListener(topics = "my-annotated-topic")
8484
public void processMessage(MyPojo message) {
8585
// ... message processing
@@ -94,7 +94,7 @@ public RetryTopicConfiguration myRetryTopic(KafkaTemplate<String, MyPojo> templa
9494
.newInstance()
9595
.fixedBackOff(3_000)
9696
.maxAttempts(5)
97-
.useSingleTopicForFixedDelays()
97+
.useSingleTopicForSameIntervals()
9898
.create(template);
9999
}
100100
----

spring-kafka/src/main/java/org/springframework/kafka/annotation/EnableKafkaRetryTopic.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,7 @@
3939
* &#064;Component
4040
* public class MyListener {
4141
*
42-
* &#064;RetryableTopic(fixedDelayTopicStrategy = FixedDelayStrategy.SINGLE_TOPIC, backoff = @Backoff(4000))
42+
* &#064;RetryableTopic(sameIntervalTopicReuseStrategy = SameIntervalTopicReuseStrategy.SINGLE_TOPIC, backoff = @Backoff(4000))
4343
* &#064;KafkaListener(topics = "myTopic")
4444
* public void listen(String message, @Header(KafkaHeaders.RECEIVED_TOPIC) String receivedTopic) {
4545
* logger.info("Message {} received in topic {} ", message, receivedTopic);

0 commit comments

Comments
 (0)