Package org.apache.kafka.streams.errors

package org.apache.kafka.streams.errors

Provides common exception classes for Streams applications.

Related Packages

Package	Description
org.apache.kafka.streams	Provides the Kafka Streams library for building streaming data applications.
org.apache.kafka.streams.kstream	Provides a high-level programming model (DSL) to express a (stateful) data flow computation over input streams and tables.
org.apache.kafka.streams.processor	Provides a low-level programming model (Processor API, aka, PAPI) to express a (stateful) data flow computation over input topics.
org.apache.kafka.streams.query	Provides a query API (aka Interactive Queries) over state stores, for extracting data from a stateful Kafka Streams application.
org.apache.kafka.streams.state	Provides interfaces for managing the intermediate state of a stateful streams application.
org.apache.kafka.streams.test	Provides classes for testing Kafka Streams applications with mocked inputs.

Class	Description
BrokerNotFoundException	Indicates that none of the specified brokers could be found.
DefaultProductionExceptionHandler	ProductionExceptionHandler that always instructs streams to fail when an exception happens while attempting to produce result records.
DeserializationExceptionHandler	Interface that specifies how an exception from source node deserialization (e.g., reading from Kafka) should be handled.
DeserializationExceptionHandler.DeserializationHandlerResponse	Enumeration that describes the response from the exception handler.
InvalidStateStoreException	Indicates that there was a problem when trying to access a StateStore.
InvalidStateStorePartitionException	Indicates that the specific state store being queried via StoreQueryParameters used a partitioning that is not assigned to this instance.
LockException	Indicates that the state store directory lock could not be acquired because another thread holds the lock.
LogAndContinueExceptionHandler	Deserialization handler that logs a deserialization exception and then signals the processing pipeline to continue processing more records.
LogAndFailExceptionHandler	Deserialization handler that logs a deserialization exception and then signals the processing pipeline to stop processing more records and fail.
MissingSourceTopicException
ProcessorStateException	Indicates a processor state operation (e.g. put, get) has failed.
ProductionExceptionHandler	Interface that specifies how an exception when attempting to produce a result to Kafka should be handled.
ProductionExceptionHandler.ProductionExceptionHandlerResponse
StateStoreMigratedException	Indicates that the state store being queried is closed although the Kafka Streams state is RUNNING or REBALANCING.
StateStoreNotAvailableException	Indicates that the state store being queried is already closed.
StreamsException	StreamsException is the top-level exception type generated by Kafka Streams, and indicates errors have occurred during a StreamThread's processing.
StreamsNotStartedException	Indicates that Kafka Streams is in state CREATED and thus state stores cannot be queries yet.
StreamsRebalancingException	Indicates that Kafka Streams is in state REBALANCING and thus cannot be queried by default.
StreamsStoppedException	Indicates that Kafka Streams is in a terminating or terminal state, such as KafkaStreams.State.PENDING_SHUTDOWN,KafkaStreams.State.PENDING_ERROR,KafkaStreams.State.NOT_RUNNING, or KafkaStreams.State.ERROR.
StreamsUncaughtExceptionHandler
StreamsUncaughtExceptionHandler.StreamThreadExceptionResponse	Enumeration that describes the response from the exception handler.
TaskAssignmentException	Indicates a run time error incurred while trying to assign stream tasks to threads.
TaskCorruptedException	Indicates a specific task is corrupted and need to be re-initialized.
TaskIdFormatException	Indicates a run time error incurred while trying parse the task id from the read string.
TaskMigratedException	Indicates that all tasks belongs to the thread have migrated to another thread.
TopologyException	Indicates a pre run time error occurred while parsing the logical topology to construct the physical processor topology.
UnknownStateStoreException	Indicates that the state store being queried is unknown, i.e., the state store does either not exist in your topology or it is not queryable.
UnknownTopologyException	Indicates that the NamedTopology being looked up does not exist in this application