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.InvalidStateStorePartitionException extends InvalidStateStoreException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.streams.errors.LockException extends StreamsException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.streams.errors.MissingSourceTopicException 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.StateStoreMigratedException extends InvalidStateStoreException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.streams.errors.StateStoreNotAvailableException extends InvalidStateStoreException 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.StreamsNotStartedException extends InvalidStateStoreException implements Serializable

serialVersionUID:

1L

Class org.apache.kafka.streams.errors.StreamsRebalancingException extends InvalidStateStoreException 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

corruptedTasks

Set<E> corruptedTasks

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

Class org.apache.kafka.streams.errors.UnknownStateStoreException extends InvalidStateStoreException implements Serializable

serialVersionUID:

1L