Module: Karafka::Pro::Cleaner::Errors

Defined in:

lib/karafka/pro/cleaner/errors.rb

Overview

Cleaner related errors

Constant Summary

BaseError =

Base for all the clearer errors

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

MessageCleanedError =

Raised when trying to deserialize a message that has already been cleaned

Class.new(BaseError)