Namespace Org.Apache.Kafka.Streams.Errors

Classes

BrokerNotFoundException

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/errors/BrokerNotFoundException.html

DefaultProductionExceptionHandler

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/errors/DefaultProductionExceptionHandler.html

DeserializationExceptionHandler

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/errors/DeserializationExceptionHandler.html

DeserializationExceptionHandler.DeserializationHandlerResponse

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/errors/DeserializationExceptionHandler.DeserializationHandlerResponse.html

ErrorHandlerContext

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/errors/ErrorHandlerContext.html

InvalidStateStoreException

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/errors/InvalidStateStoreException.html

InvalidStateStorePartitionException

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/errors/InvalidStateStorePartitionException.html

LockException

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/errors/LockException.html

LogAndContinueExceptionHandler

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/errors/LogAndContinueExceptionHandler.html

LogAndContinueProcessingExceptionHandler

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/errors/LogAndContinueProcessingExceptionHandler.html

LogAndFailExceptionHandler

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/errors/LogAndFailExceptionHandler.html

LogAndFailProcessingExceptionHandler

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/errors/LogAndFailProcessingExceptionHandler.html

MissingSourceTopicException

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/errors/MissingSourceTopicException.html

ProcessingExceptionHandler

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/errors/ProcessingExceptionHandler.html

ProcessingExceptionHandler.ProcessingHandlerResponse

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/errors/ProcessingExceptionHandler.ProcessingHandlerResponse.html

ProcessorStateException

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/errors/ProcessorStateException.html

ProductionExceptionHandler

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/errors/ProductionExceptionHandler.html

ProductionExceptionHandler.ProductionExceptionHandlerResponse

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/errors/ProductionExceptionHandler.ProductionExceptionHandlerResponse.html

ProductionExceptionHandler.SerializationExceptionOrigin

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/errors/ProductionExceptionHandler.SerializationExceptionOrigin.html

StateStoreMigratedException

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/errors/StateStoreMigratedException.html

StateStoreNotAvailableException

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/errors/StateStoreNotAvailableException.html

StreamsException

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/errors/StreamsException.html

StreamsNotStartedException

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/errors/StreamsNotStartedException.html

StreamsRebalancingException

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/errors/StreamsRebalancingException.html

StreamsStoppedException

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/errors/StreamsStoppedException.html

StreamsUncaughtExceptionHandler

Listener for Kafka StreamsUncaughtExceptionHandler. Extends MASES.JCOBridge.C2JBridge.JVMBridgeListener, implements IStreamsUncaughtExceptionHandler

StreamsUncaughtExceptionHandler.StreamThreadExceptionResponse

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/errors/StreamsUncaughtExceptionHandler.StreamThreadExceptionResponse.html

StreamsUncaughtExceptionHandlerDirect

Direct override of StreamsUncaughtExceptionHandler or its generic type if there is one

TaskAssignmentException

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/errors/TaskAssignmentException.html

TaskCorruptedException

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/errors/TaskCorruptedException.html

TaskIdFormatException

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/errors/TaskIdFormatException.html

TaskMigratedException

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/errors/TaskMigratedException.html

TopologyException

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/errors/TopologyException.html

UnknownStateStoreException

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/errors/UnknownStateStoreException.html

UnknownTopologyException

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/errors/UnknownTopologyException.html

Interfaces

IDeserializationExceptionHandler

.NET interface for TO BE DEFINED FROM USER

IErrorHandlerContext

.NET interface for TO BE DEFINED FROM USER

IProcessingExceptionHandler

.NET interface for TO BE DEFINED FROM USER

IProductionExceptionHandler

.NET interface for TO BE DEFINED FROM USER

IStreamsUncaughtExceptionHandler

Listener for Kafka StreamsUncaughtExceptionHandler. Extends MASES.JCOBridge.C2JBridge.IJVMBridgeBase