Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

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.
    */
    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()

...