wcarlson5 commented on a change in pull request #9273:
URL: https://github.com/apache/kafka/pull/9273#discussion_r488194586
##########
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##########
@@ -931,6 +932,22 @@ public synchronized boolean close(final long timeout,
final TimeUnit timeUnit) {
return close(timeoutMs);
}
+ /**
+ * Attempts to shutdown an application.
+ * If there is an alive StreamThread it will succeed, if there is not it
will fail
+ *
+ * @return Will return true if shutdown is initiated false if it is not
possible.
+ */
+ public boolean shutdownApplication() {
Review comment:
This is the idea for a shutdown that users can initiate without throwing
an exception. It will still need at least one alive stream thread
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
