THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
| Code Block | ||||
|---|---|---|---|---|
| ||||
/**
* Should be thrown in reaction to an event that necessitates the closure of the entire Streams application.
*
*/
public class ShutdownRequestedException extends StreamsException {
public ShutdownRequestedException(final String message) {
super(message);
}
public ShutdownRequestedException(final String message, final Throwable throwable) {
super(message, throwable);
}
public ShutdownRequestedException(final Throwable throwable) {
super(throwable);
}
} |
KafkaStreams.java
| Code Block | ||
|---|---|---|
| ||
/**
* 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(); |
Proposed Changes
We propose to add a new exception that will cause all clients in the application to be shutdown when thrown.
...