Interface that specifies how an exception from source node deserialization (e.g., reading from Kafka) should be handled.
Interface that specifies how an exception when attempting to produce a result to Kafka should be handled.
ProductionExceptionHandler that always instructs streams to fail when an exception
happens while attempting to produce result records.
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.
Enumeration that describes the response from the exception handler.
Indicates that none of the specified
could be found.
Indicates that there was a problem when trying to access a
StateStore, i.e, the Store is no longer valid because it is
closed or doesn't exist any more due to a rebalance.
Indicates that the state store directory lock could not be acquired because another thread holds the lock.
Indicates a processor state operation (e.g.
StreamsException is the top-level exception type generated by Kafka Streams.
Indicates a run time error incurred while trying to assign
stream tasks to
Indicates a run time error incurred while trying parse the
from the read string.
Indicates that a task got migrated to another thread.
Indicates a pre run time error occurred while parsing the
to construct the
physical processor topology.