Skip to content

Commit f8d370b

Browse files
Add an java docs.
Signed-off-by: chickenchickenlove <[email protected]>
1 parent 606fcfc commit f8d370b

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

spring-kafka/src/main/java/org/springframework/kafka/listener/ListenerUtils.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -152,6 +152,7 @@ public static void conditionalSleep(Supplier<Boolean> shouldSleepCondition, long
152152

153153
/**
154154
* Sleep for the desired timeout, as long as shouldSleepCondition supplies true.
155+
* This method requires that the consumer is paused; otherwise, ConsumerRecord may be lost.
155156
* @param shouldSleepCondition to.
156157
* @param interval the timeout.
157158
* @param consumer the kafka consumer to call poll().

0 commit comments

Comments
 (0)