Module: Karafka::Pro::Processing::Strategies::Aj::LrjMom

Includes:

Lrj::Mom

Included in:

DlqFtrLrjMom, DlqFtrLrjMomVp, DlqLrjMom, DlqLrjMomVp

Defined in:

lib/karafka/pro/processing/strategies/aj/lrj_mom.rb

Overview

ActiveJob enabled Long-Running Job enabled Manual offset management enabled

Constant Summary

FEATURES =

Features for this strategy

%i[
  active_job
  long_running_job
  manual_offset_management
].freeze

Method Summary

Methods included from Lrj::Mom

#handle_after_consume, #handle_before_schedule_consume, #handle_revoked

Methods included from Default

#handle_after_consume, #handle_before_consume, #handle_before_schedule_consume, #handle_before_schedule_tick, #handle_consume, #handle_revoked, #handle_tick, #mark_as_consumed, #mark_as_consumed!, #mark_in_transaction, #store_offset_metadata, #transaction

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

#commit_offsets, #commit_offsets!, #handle_after_consume, #handle_before_consume, #handle_consume, #handle_eofed, #handle_idle, #handle_initialized, #handle_revoked, #handle_shutdown, #mark_as_consumed, #mark_as_consumed!

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

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