Serialized Form
-
Package org.apache.kafka.streams.errors
-
Class org.apache.kafka.streams.errors.BrokerNotFoundException extends StreamsException implements Serializable
- serialVersionUID:
- 1L
-
Class org.apache.kafka.streams.errors.InvalidStateStoreException extends StreamsException implements Serializable
- serialVersionUID:
- 1L
-
Class org.apache.kafka.streams.errors.LockException extends StreamsException implements Serializable
- serialVersionUID:
- 1L
-
Class org.apache.kafka.streams.errors.ProcessorStateException extends StreamsException implements Serializable
- serialVersionUID:
- 1L
-
Class org.apache.kafka.streams.errors.StreamsException extends org.apache.kafka.common.KafkaException implements Serializable
- serialVersionUID:
- 1L
-
Class org.apache.kafka.streams.errors.TaskAssignmentException extends StreamsException implements Serializable
- serialVersionUID:
- 1L
-
Class org.apache.kafka.streams.errors.TaskCorruptedException extends StreamsException implements Serializable
-
Serialized Fields
-
taskWithChangelogs
java.util.Map<TaskId,java.util.Collection<org.apache.kafka.common.TopicPartition>> taskWithChangelogs
-
-
-
Class org.apache.kafka.streams.errors.TaskIdFormatException extends StreamsException implements Serializable
- serialVersionUID:
- 1L
-
Class org.apache.kafka.streams.errors.TaskMigratedException extends StreamsException implements Serializable
- serialVersionUID:
- 1L
-
Class org.apache.kafka.streams.errors.TopologyException extends StreamsException implements Serializable
- serialVersionUID:
- 1L
-
-
Package org.apache.kafka.streams.errors.mapr
-
Class org.apache.kafka.streams.errors.mapr.InternalStreamNotExistException extends StreamsException implements Serializable
- serialVersionUID:
- 1L
-