Class ApiUtils
- java.lang.Object
-
- org.apache.kafka.streams.internals.ApiUtils
-
public final class ApiUtils extends java.lang.Object
-
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static java.lang.String
prepareMillisCheckFailMsgPrefix(java.lang.Object value, java.lang.String name)
Generates the prefix message for validateMillisecondXXXXXX() utilitystatic long
validateMillisecondDuration(java.time.Duration duration, java.lang.String messagePrefix)
Validates that milliseconds fromduration
can be retrieved.static long
validateMillisecondInstant(java.time.Instant instant, java.lang.String messagePrefix)
Validates that milliseconds frominstant
can be retrieved.
-
-
-
Method Detail
-
validateMillisecondDuration
public static long validateMillisecondDuration(java.time.Duration duration, java.lang.String messagePrefix)
Validates that milliseconds fromduration
can be retrieved.- Parameters:
duration
- Duration to check.messagePrefix
- Prefix text for an error message.- Returns:
- Milliseconds from
duration
.
-
validateMillisecondInstant
public static long validateMillisecondInstant(java.time.Instant instant, java.lang.String messagePrefix)
Validates that milliseconds frominstant
can be retrieved.- Parameters:
instant
- Instant to check.messagePrefix
- Prefix text for an error message.- Returns:
- Milliseconds from
instant
.
-
prepareMillisCheckFailMsgPrefix
public static java.lang.String prepareMillisCheckFailMsgPrefix(java.lang.Object value, java.lang.String name)
Generates the prefix message for validateMillisecondXXXXXX() utility- Parameters:
value
- Object to be converted to millisecondsname
- Object name- Returns:
- Error message prefix to use in exception
-
-