THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Currently there is not a native way to shutdown and entire KStreams application from a StreamThread. This functionality would be useful for immediately halting processing to prevent data from being corrupted. This would help recover form errors such as a source topic deleted.
Public Interfaces
Code Block | ||||||
---|---|---|---|---|---|---|
| ||||||
Wiki Markup | ||||||
package org.apache.kafka.streams.errors;
/**
* 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);
}
} |
...