Skip to content

Commit 9f03731

Browse files
jucosoringaryrussell
authored andcommitted
GH-2511: Fix code samples
1 parent 016e9b4 commit 9f03731

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
@@ -370,7 +370,7 @@ public RetryTopicConfiguration myRetryTopic(KafkaTemplate<String, MyPojo> templa
370370
.newInstance()
371371
.fixedBackoff(3000)
372372
.maxAttempts(4)
373-
.build();
373+
.create(template);
374374
}
375375
----
376376
====
@@ -386,7 +386,7 @@ public RetryTopicConfiguration myRetryTopic(KafkaTemplate<String, MyPojo> templa
386386
.newInstance()
387387
.customBackOff(new MyCustomBackOffPolicy())
388388
.maxAttempts(5)
389-
.build();
389+
.create(template);
390390
}
391391
----
392392
====
@@ -424,7 +424,7 @@ public RetryTopicConfiguration myRetryTopic(KafkaTemplate<String, MyPojo> templa
424424
.fixedBackoff(3000)
425425
.maxAttempts(5)
426426
.useSingleTopicForFixedDelays()
427-
.build();
427+
.create(template);
428428
}
429429
----
430430
====
@@ -456,7 +456,7 @@ public RetryTopicConfiguration myRetryTopic(KafkaTemplate<String, MyPojo> templa
456456
.newInstance()
457457
.fixedBackoff(2000)
458458
.timeoutAfter(5000)
459-
.build();
459+
.create(template);
460460
}
461461
----
462462
====

0 commit comments

Comments
 (0)