Skip to content

Commit f69c257

Browse files
jucosoringaryrussell
authored andcommitted
GH-2511: Fix code samples
1 parent 481fcf8 commit f69c257

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

spring-kafka-docs/src/main/asciidoc/retrytopic.adoc

+4-4
Original file line numberDiff line numberDiff line change
@@ -353,7 +353,7 @@ public RetryTopicConfiguration myRetryTopic(KafkaTemplate<String, MyPojo> templa
353353
.newInstance()
354354
.fixedBackoff(3000)
355355
.maxAttempts(4)
356-
.build();
356+
.create(template);
357357
}
358358
----
359359
====
@@ -369,7 +369,7 @@ public RetryTopicConfiguration myRetryTopic(KafkaTemplate<String, MyPojo> templa
369369
.newInstance()
370370
.customBackOff(new MyCustomBackOffPolicy())
371371
.maxAttempts(5)
372-
.build();
372+
.create(template);
373373
}
374374
----
375375
====
@@ -407,7 +407,7 @@ public RetryTopicConfiguration myRetryTopic(KafkaTemplate<String, MyPojo> templa
407407
.fixedBackoff(3000)
408408
.maxAttempts(5)
409409
.useSingleTopicForFixedDelays()
410-
.build();
410+
.create(template);
411411
}
412412
----
413413
====
@@ -439,7 +439,7 @@ public RetryTopicConfiguration myRetryTopic(KafkaTemplate<String, MyPojo> templa
439439
.newInstance()
440440
.fixedBackoff(2000)
441441
.timeoutAfter(5000)
442-
.build();
442+
.create(template);
443443
}
444444
----
445445
====

0 commit comments

Comments
 (0)