Module: Karafka::Pro::Admin::Recovery::Errors

Defined in:

lib/karafka/pro/admin/recovery/errors.rb

Overview

Recovery related errors

Constant Summary

BaseError =

Base for all the recovery errors

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

MetadataError =

Raised when required cluster metadata cannot be retrieved (topic, partition, or broker not found)

Class.new(BaseError)

PartitionOutOfRangeError =

Raised when a partition number is outside the valid range for __consumer_offsets

Class.new(BaseError)