Module: Karafka::Pro::Processing::Strategies::Mom

Includes:
Default
Included in:
AjMom
Defined in:
lib/karafka/pro/processing/strategies/mom.rb

Overview

Manual offset management enabled

Constant Summary collapse

FEATURES =

Features for this strategy

%i[
  manual_offset_management
].freeze

Instance Method Summary collapse

Methods included from Default

#handle_before_consume, #handle_before_enqueue, #handle_consume, #handle_revoked

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

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

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

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

Instance Method Details

#handle_after_consume ⇒ Object

When mom is enabled, we do not mark messages as consumed after processing



28
29
30
31
32
33
34
35
36
37
38
 
# File 'lib/karafka/pro/processing/strategies/mom.rb', line 28

def handle_after_consume
  coordinator.on_finished do
    return if revoked?

    if coordinator.success?
      coordinator.pause_tracker.reset
    else
      retry_after_pause
    end
  end
end