Package org.apache.kafka.streams.internals

Class ApiUtils

java.lang.Object

org.apache.kafka.streams.internals.ApiUtils

public final class ApiUtils
extends Object

Method Summary

Modifier and Type	Method	Description
static String	prepareMillisCheckFailMsgPrefix(Object value, String name)	Generates the prefix message for validateMillisecondXXXXXX() utility
static long	validateMillisecondDuration(Duration duration, String messagePrefix)	Validates that milliseconds from duration can be retrieved.
static long	validateMillisecondInstant(Instant instant, String messagePrefix)	Validates that milliseconds from instant can be retrieved.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

validateMillisecondDuration

public static long validateMillisecondDuration(Duration duration,
                                               String messagePrefix)

Validates that milliseconds from duration can be retrieved.

Parameters:

duration - Duration to check.

messagePrefix - Prefix text for an error message.

Returns:

Milliseconds from duration.

validateMillisecondInstant

public static long validateMillisecondInstant(Instant instant,
                                              String messagePrefix)

Validates that milliseconds from instant can be retrieved.

Parameters:

instant - Instant to check.

messagePrefix - Prefix text for an error message.

Returns:

Milliseconds from instant.

prepareMillisCheckFailMsgPrefix

public static String prepareMillisCheckFailMsgPrefix(Object value,
                                                     String name)

Generates the prefix message for validateMillisecondXXXXXX() utility

Parameters:

value - Object to be converted to milliseconds

name - Object name

Returns:

Error message prefix to use in exception