Module: Karafka::Pro::Processing::Strategies::Dlq::LrjMomVp

Includes:

LrjMom, Vp

Defined in:

lib/karafka/pro/processing/strategies/dlq/lrj_mom_vp.rb

Overview

Strategy for supporting DLQ with Mom, LRJ and VP enabled

Constant Summary

FEATURES =

Feature set for this strategy

%i[
  dead_letter_queue
  long_running_job
  manual_offset_management
  virtual_partitions
].freeze

Constants included from Lrj::Default

Lrj::Default::MAX_PAUSE_TIME

Method Summary

Methods included from LrjMom

#handle_after_consume

Methods included from Lrj

#handle_after_consume

Methods included from Lrj::Default

#handle_after_consume, #handle_before_enqueue, #handle_revoked

Methods included from Karafka::Pro::Processing::Strategies::Default

#handle_after_consume, #handle_before_consume, #handle_before_enqueue, #handle_consume, #handle_revoked

Methods included from Karafka::Processing::Strategies::Default

#commit_offsets, #commit_offsets!, #handle_after_consume, #handle_before_consume, #handle_before_enqueue, #handle_consume, #handle_idle, #handle_revoked, #handle_shutdown, #mark_as_consumed, #mark_as_consumed!

Methods included from Karafka::Processing::Strategies::Base

#handle_after_consume, #handle_before_consume, #handle_before_enqueue, #handle_consume, #handle_idle, #handle_revoked, #handle_shutdown

Methods included from Default

#build_dlq_message, #dispatch_to_dlq, #dispatch_to_dlq?, #find_skippable_message, #handle_after_consume

Methods included from Vp::Default

#collapsed?, #failing?, #mark_as_consumed, #mark_as_consumed!