ableegoldman commented on a change in pull request #11123:
URL: https://github.com/apache/kafka/pull/11123#discussion_r675938650
##########
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##########
@@ -235,10 +238,26 @@
this.validTransitions.addAll(Arrays.asList(validTransitions));
}
+ public boolean hasNotStarted() {
+ return equals(CREATED);
+ }
+
public boolean isRunningOrRebalancing() {
return equals(RUNNING) || equals(REBALANCING);
}
+ public boolean isShuttingDown() {
+ return equals(PENDING_SHUTDOWN) || equals(PENDING_ERROR);
+ }
+
+ public boolean hasCompletedShutdown() {
+ return equals(NOT_RUNNING) || equals(ERROR);
+ }
+
+ public boolean hasStartedOrFinishedShuttingDown() {
Review comment:
Technically this one is not used anywhere yet, but I intend to use it in
[#10788](https://github.com/apache/kafka/pull/10788) so I just went ahead and
added it here. Happy to remove it until it's actually needed if anyone prefers
--
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: jira-unsubscr...@kafka.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
