public static enum KafkaStreams.State extends Enum<KafkaStreams.State>
+--------------+ +<----- | Created | | +-----+--------+ | | | v | +-----+--------+ +<----- | Rebalancing | <----+ | +--------------+ | | | | | | +--------------+ | +-----> | Running | ---->+ | +-----+--------+ | | | v | +-----+--------+ +-----> | Pending | | Shutdown | +-----+--------+ | v +-----+--------+ | Not Running | +--------------+
Enum Constant and Description |
---|
CREATED |
NOT_RUNNING |
PENDING_SHUTDOWN |
REBALANCING |
RUNNING |
Modifier and Type | Method and Description |
---|---|
boolean |
isCreatedOrRunning() |
boolean |
isRunning() |
boolean |
isValidTransition(KafkaStreams.State newState) |
static KafkaStreams.State |
valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static KafkaStreams.State[] |
values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
public static final KafkaStreams.State CREATED
public static final KafkaStreams.State RUNNING
public static final KafkaStreams.State REBALANCING
public static final KafkaStreams.State PENDING_SHUTDOWN
public static final KafkaStreams.State NOT_RUNNING
public static KafkaStreams.State[] values()
for (KafkaStreams.State c : KafkaStreams.State.values()) System.out.println(c);
public static KafkaStreams.State valueOf(String name)
name
- the name of the enum constant to be returned.IllegalArgumentException
- if this enum type has no constant with the specified nameNullPointerException
- if the argument is nullpublic boolean isRunning()
public boolean isCreatedOrRunning()
public boolean isValidTransition(KafkaStreams.State newState)