Module: Karafka::Pro::Processing::Strategies::AjDlqLrjMom

Includes:

AjDlqMom, AjLrjMom

Defined in:

lib/karafka/pro/processing/strategies/aj_dlq_lrj_mom.rb

Overview

ActiveJob enabled DLQ enabled Long-Running Job enabled Manual offset management enabled

This case is a bit of special. Please see the ‘AjDlqMom` for explanation on how the offset management works in this case.

Constant Summary

FEATURES =

Features for this strategy

%i[
  active_job
  long_running_job
  manual_offset_management
  dead_letter_queue
].freeze

Method Summary

Methods included from AjDlqMom

#handle_after_consume

Methods included from DlqMom

#handle_after_consume

Methods included from Dlq

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

Methods included from Default

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

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

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

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

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

Methods included from LrjMom

#handle_after_consume, #handle_before_enqueue, #handle_revoked