Module: Karafka::Errors

Defined in:
lib/karafka/errors.rb

Overview

Namespace used to encapsulate all the internal errors of Karafka

Constant Summary collapse

BaseError =

Base class for all the Karafka internal errors

Class.new(StandardError)
NonMatchingRouteError =

Raised when router receives topic name which does not correspond with any routes This can only happen in a case when:

- you've received a message and we cannot match it with a consumer
- you've changed the routing, so router can no longer associate your topic to
  any consumer
- or in a case when you do a lot of meta-programming and you change routing/etc on runtime

In case this happens, you will have to create a temporary route that will allow you to “eat” everything from the Sidekiq queue.

See Also:

Class.new(BaseError)
InvalidConfigurationError =

Raised when configuration doesn’t match with validation contract

Class.new(BaseError)
MissingBootFileError =

Raised when we try to use Karafka CLI commands (except install) without a boot file

Class.new(BaseError)
ForcefulShutdownError =

Raised when we’ve waited enough for shutting down a non-responsive process

Class.new(BaseError)
JobsQueueSynchronizationError =

Raised when the jobs queue receives a job that should not be received as it would cause the processing to go out of sync. We should never process in parallel data from the same topic partition (unless virtual partitions apply)

Class.new(BaseError)
TopicNotFoundError =

Raised when given topic is not found while expected

Class.new(BaseError)
UnsupportedCaseError =

This should never happen. Please open an issue if it does.

Class.new(BaseError)
InvalidLicenseTokenError =

Raised when the license token is not valid

Class.new(BaseError)
MessageClearedError =

Raised on attempt to deserializer a cleared message

Class.new(BaseError)
InvalidCoordinatorStateError =

This should never happen. Please open an issue if it does.

Class.new(BaseError)
StrategyNotFoundError =

This should never happen. Please open an issue if it does.

Class.new(BaseError)
InvalidRealOffsetUsageError =

This should never happen. Please open an issue if it does.

Class.new(BaseError)
InvalidTimeBasedOffsetError =

This should never happen. Please open an issue if it does.

Class.new(BaseError)
ResultNotVisibleError =

For internal usage only Raised when we run operations that require certain result but despite successfully finishing it is not yet available due to some synchronization mechanisms and caches

Class.new(BaseError)