Skip to content

Commit ad1fca4

Browse files
committed
Replace FixedDelayStrategy to SameIntervalTopicReuseStrategy in docs
Signed-off-by: Seonghyeon Cho <[email protected]>
1 parent b68db55 commit ad1fca4

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

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

Lines changed: 1 addition & 1 deletion
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

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)