Module: Karafka::Pro::ScheduledMessages::Errors

Defined in:

lib/karafka/pro/scheduled_messages/errors.rb

Overview

Scheduled Messages related errors

Constant Summary

BaseError =

Base for all the recurring tasks errors

Class.new(::Karafka::Errors::BaseError)

IncompatibleSchemaError =

Raised when the scheduled messages processor is older than the messages we started to receive. In such cases we stop because there may be schema changes.

Class.new(BaseError)