Package org.apache.kafka.streams.errors
package org.apache.kafka.streams.errors
Provides common exception classes for Streams applications.
-
ClassDescriptionIndicates that none of the specified
brokerscould be found.ProductionExceptionHandlerthat always instructs streams to fail when an exception happens while attempting to produce result records.Interface that specifies how an exception from source node deserialization (e.g., reading from Kafka) should be handled.Enumeration that describes the response from the exception handler.This interface allows user code to inspect the context of a record that has failed during processing.Indicates that there was a problem when trying to access aStateStore.Indicates that the specific state store being queried viaStoreQueryParametersused a partitioning that is not assigned to this instance.Indicates that the state store directory lock could not be acquired because another thread holds the lock.Deserialization handler that logs a deserialization exception and then signals the processing pipeline to continue processing more records.Processing exception handler that logs a processing exception and then signals the processing pipeline to continue processing more records.Deserialization handler that logs a deserialization exception and then signals the processing pipeline to stop processing more records and fail.Processing exception handler that logs a processing exception and then signals the processing pipeline to stop processing more records and fail.An interface that allows user code to inspect a record that has failed processingIndicates a processor state operation (e.g.Interface that specifies how an exception when attempting to produce a result to Kafka should be handled.Indicates that the state store being queried is closed although the Kafka Streams state isRUNNINGorREBALANCING.Indicates that the state store being queried is already closed.StreamsExceptionis the top-level exception type generated by Kafka Streams, and indicates errors have occurred during aStreamThread'sprocessing.Indicates that Kafka Streams is in stateCREATEDand thus state stores cannot be queries yet.Indicates that Kafka Streams is in stateREBALANCINGand thus cannot be queried by default.Indicates that Kafka Streams is in a terminating or terminal state, such asKafkaStreams.State.PENDING_SHUTDOWN,KafkaStreams.State.PENDING_ERROR,KafkaStreams.State.NOT_RUNNING, orKafkaStreams.State.ERROR.Enumeration that describes the response from the exception handler.Indicates a run time error incurred while trying to assignstream taskstothreads.Indicates a specific task is corrupted and need to be re-initialized.Indicates a run time error incurred while trying parse thetask idfrom the read string.Indicates that all tasks belongs to the thread have migrated to another thread.Indicates a pre run time error occurred while parsing thelogical topologyto construct thephysical processor topology.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.Indicates that theNamedTopologybeing looked up does not exist in this application