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.Indicates that there was a problem when trying to access a
StateStore.Indicates that the specific state store being queried via
StoreQueryParametersused 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.Deserialization handler that logs a deserialization exception and then signals the processing pipeline to stop processing more records and fail.Indicates 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 already closed.
StreamsExceptionis the top-level exception type generated by Kafka Streams, and indicates errors have occurred during a
StreamThread'sprocessing.Indicates that Kafka Streams is in state
CREATEDand thus state stores cannot be queries yet.Indicates that Kafka Streams is in state
REBALANCINGand thus cannot be queried by default.Enumeration that describes the response from the exception handler.Indicates a run time error incurred while trying to assign
threads.Indicates a specific task is corrupted and need to be re-initialized.Indicates a run time error incurred while trying parse the
task 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 the
logical topologyto construct the
physical 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.