THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block |
---|
public enum FailureReason {
/**
* Failure indicating that the store doesn't know how to handle the given query.
*/
UNKNOWN_QUERY_TYPE,
/**
* The query required to execute on an active task (via {@link StateQueryRequest#requireActive()}),
* but while executing the query, the task was either a Standby task, or it was an Active task
* not in the RUNNING state. The failure message will contain the reason for the failure.
* <p>
* The caller should either try again later or try a different replica.
*/
NOT_ACTIVE,
/**
* Failure indicating that the store partition is not (yet) up to the desired bound.
* The caller should either try again later or try a different replica.
*/
NOT_UP_TO_BOUND,
/**
* Failure indicating that the requested store partition is not present on the local
* KafkaStreams instance. It may have been migrated to another instance during a rebalance.
* The caller is recommended to try a different replica.
*/
NOT_PRESENT,
/**
* The requested store partition does not exist at all. For example, partition 4 was requested,
* but the store in question only has 4 partitions (0 through 3).
*/
DOES_NOT_EXIST;
/**
* The store that handled the query got an exception during query execution. The message
* will contain the exception details. Depending on the nature of the exception, the caller
* may be able to retry this instance or may need to try a different instance.
*/
STORE_EXCEPTION; } |
Position
A class representing a processing state position in terms of its inputs: a vector or (topic, partition, offset) components.
...