gharris1727 commented on code in PR #12826:
URL: https://github.com/apache/kafka/pull/12826#discussion_r1015749550
##########
clients/src/main/java/org/apache/kafka/common/utils/Timer.java:
##########
@@ -172,6 +172,17 @@ public long currentTimeMs() {
return currentTimeMs;
}
+ /**
+ * Get the deadline time in milliseconds when this timer would expire. The
deadlineMs time
+ * is generally updated through {@link #reset(long)} method or {@link
#updateAndReset(long)}
+ * method call.
+ *
+ * @return The deadline time in milliseconds at which the timer would
expire.
+ */
+ public long deadlineMs() {
+ return deadlineMs;
+ }
+
Review Comment:
This method seems to only be useful in the test assertions, and that doesn't
seem like a good enough reason to expose this functionality in the common utils.
--
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
