public interface ExternalStore
extends org.apache.kafka.common.Configurable
Modifier and Type | Method and Description |
---|---|
boolean |
failed()
Returns true if the external store has failed and retries have timed out.
|
void |
start(int generationId)
Starts consuming metadata from the external store.
|
void |
stop(java.lang.Integer generationId)
Stops consuming metadata from the external store if the provided generation
id is null or equal to the current generation id of this store.
|
void start(int generationId)
generationId
- The generation id of the writervoid stop(java.lang.Integer generationId)
generationId
- The generation id to match or null to match any generationboolean failed()