THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block |
---|
KafkaStreams.java
/*
Paused topologies will only skip over a) processing, b) punctuation, and c) standby tasks.
Notably, paused topologies will still poll Kafka consumers, and commit offsets.
This method sets transient state that is not maintained or managed among instances.
Note that pause() can be called before start() in order to start a KafkaStreams instance in a manner where the processing
is paused as described, but the consumers are started up.
*/
public void pause()
// Returns the state of the metadata. The last run through the topology may still be executing.
public boolean isPaused()
public void resume() |
...