Module: Karafka::Processing::Strategies::AjMom

Includes:

Mom

Defined in:

lib/karafka/processing/strategies/aj_mom.rb

Overview

ActiveJob enabled Manual offset management enabled

This is the default AJ strategy since AJ cannot be used without MOM

Constant Summary

FEATURES =

Apply strategy when only when using AJ with MOM

%i[
  active_job
  manual_offset_management
].freeze

Method Summary

Methods included from Mom

#handle_after_consume

Methods included from 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 Base

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