BrokerNotFoundException
, InvalidStateStoreException
, LockException
, ProcessorStateException
, TaskAssignmentException
, TaskIdFormatException
, TaskMigratedException
, TopologyException
public class StreamsException extends KafkaException
StreamsException
is the top-level exception type generated by Kafka Streams.Constructor | Description |
---|---|
StreamsException(java.lang.String message) |
|
StreamsException(java.lang.String message,
java.lang.Throwable throwable) |
|
StreamsException(java.lang.Throwable throwable) |