Module: Karafka::Pro::Processing::Strategies::Aj::FtrLrjMom
- Includes:
- Lrj::FtrMom
- Defined in:
- lib/karafka/pro/processing/strategies/aj/ftr_lrj_mom.rb
Overview
ActiveJob enabled Filtering enabled Long-Running Job enabled Manual offset management enabled
Constant Summary collapse
- FEATURES =
Features for this strategy
%i[ active_job filtering long_running_job manual_offset_management ].freeze
Constants included from Lrj::Default
Method Summary
Methods included from Lrj::FtrMom
Methods included from Lrj::Ftr
Methods included from Lrj::Default
#handle_after_consume, #handle_before_schedule_consume, #handle_revoked, #synchronize
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