THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block |
---|
KafkaStreams.java /* Paused topologies will only skip over a) processing and b) punctuation. PausedNotably, paused topologies will still poll Kafka consumers, process standBy tasks, and commit offsets. */ 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() |
...