apoorvmittal10 commented on code in PR #19759: URL: https://github.com/apache/kafka/pull/19759#discussion_r2105470732
########## server-common/src/main/java/org/apache/kafka/server/purgatory/DelayedOperation.java: ########## @@ -29,10 +28,9 @@ * a delayed fetch operation could be waiting for a given number of bytes to accumulate. * <br/> * The logic upon completing a delayed operation is defined in onComplete() and will be called exactly once. - * Once an operation is completed, isCompleted() will return true. onComplete() can be triggered by either - * forceComplete(), which forces calling onComplete() after delayMs if the operation is not yet completed, - * or tryComplete(), which first checks if the operation can be completed or not now, and if yes calls - * forceComplete(). + * Once an operation is completed, isCompleted() will return true. onComplete() is called from forceComplete(), + * which is triggered once by either expiration if the operation is not completed after delayMs, or tryComplete() Review Comment: Done. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
