jnh5y commented on code in PR #12161:
URL: https://github.com/apache/kafka/pull/12161#discussion_r879798075
##########
streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java:
##########
@@ -1662,6 +1663,51 @@ public <T> T store(final StoreQueryParameters<T>
storeQueryParameters) {
return queryableStoreProvider.getStore(storeQueryParameters);
}
+ /**
+ * This method pauses processing for the KafkaStreams instance.
+ *
+ * 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() {
Review Comment:
Yes! I added some in this commit
https://github.com/apache/kafka/pull/12161/commits/e0a80bbf31b79a1eb81bd67dff33ce81933b3e73.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
