Spring/spring-kafka
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

GH-2511: Fix code samples

Browse Source
This commit is contained in:
Sorin Jucovschi
2022-12-21 15:45:11 +02:00
committed by Gary Russell
parent 481fcf8938
commit f69c2571e1
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
spring-kafka-docs/src/main/asciidoc/retrytopic.adoc
View File

@@ -353,7 +353,7 @@ public RetryTopicConfiguration myRetryTopic(KafkaTemplate<String, MyPojo> templa
.newInstance()
.fixedBackoff(3000)
.maxAttempts(4)
.build();
.create(template);
}
----
====
@@ -369,7 +369,7 @@ public RetryTopicConfiguration myRetryTopic(KafkaTemplate<String, MyPojo> templa
.newInstance()
.customBackOff(new MyCustomBackOffPolicy())
.maxAttempts(5)
.build();
.create(template);
}
----
====
@@ -407,7 +407,7 @@ public RetryTopicConfiguration myRetryTopic(KafkaTemplate<String, MyPojo> templa
.fixedBackoff(3000)
.maxAttempts(5)
.useSingleTopicForFixedDelays()
.build();
.create(template);
}
----
====
@@ -439,7 +439,7 @@ public RetryTopicConfiguration myRetryTopic(KafkaTemplate<String, MyPojo> templa
.newInstance()
.fixedBackoff(2000)
.timeoutAfter(5000)
.build();
.create(template);
}
----
====