public class StreamsException
extends org.apache.kafka.common.KafkaExceptionStreamsException is the top-level exception type generated by Kafka Streams, and indicates errors have occurred during a StreamThread's processing. It is guaranteed that any exception thrown up to the StreamsUncaughtExceptionHandler will be of the type StreamsException. For example, any user exceptions will be wrapped as a StreamsException.| Constructor and Description |
|---|
StreamsException(String message) |
StreamsException(String message, TaskId taskId) |
StreamsException(String message, Throwable throwable) |
StreamsException(String message, Throwable throwable, TaskId taskId) |
StreamsException(Throwable throwable) |
StreamsException(Throwable throwable, TaskId taskId) |
| Modifier and Type | Method and Description |
|---|---|
void | setTaskId(TaskId taskId) |
Optional<TaskId> | taskId() |
addSuppressed, fillInStackTrace, getCause, getLocalizedMessage, getMessage, getStackTrace, getSuppressed, initCause, printStackTrace, printStackTrace, printStackTrace, setStackTrace, toStringpublic StreamsException(String message)
public StreamsException(Throwable throwable)
public Optional<TaskId> taskId()
TaskId that this exception originated from, or Optional.empty() if the exception cannot be traced back to a particular task. Note that the TaskId being empty does not guarantee that the exception wasn't directly related to a specific task.public void setTaskId(TaskId taskId)