THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||
---|---|---|
| ||
package org.apache.kafka.streams;
public enum StreamsUncaughtExceptionHandlerResponse {
SHUTDOWN_STREAM_THREAD,
REPLACE_STREAM_THREAD,
SHUTDOWN_KAFKA_STREAMS_CLIENT,
SHUTDOWN_KAFKA_STREAMS_APPLICATION;
}
public enum StreamsUncaughtExceptionHandlerResponseGlobalThread {
SHUTDOWN_KAFKA_STREAMS_CLIENT;
}
public interface StreamsUncaughtExceptionHandler {
UncaughtExceptionHandlerResponse handleUncaughtException(final Throwable exception);
StreamsUncaughtExceptionHandlerResponseGlobalThread handleExceptionInGlobalThread(final Throwable exception);
}
KafkaStreams.java/**
* Set the handler invoked when a {@link StreamsConfig#NUM_STREAM_THREADS_CONFIG internal thread} abruptly
* terminates due to an uncaught exception.
*
* @param eh the uncaught exception handler of type {@link StreamsUncaughtExceptionHandler} for all internal threads; {@code null} deletes the current handler
* @throws IllegalStateException if this {@code KafkaStreams} instance is not in state {@link State#CREATED CREATED}.
*/public void setUncaughtExceptionHandler(final StreamsUncaughtExceptionHandler eh) ; |
...