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

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

Overview

When using manual offset management, we do not mark as consumed after successful processing

Constant Summary collapse

FEATURES =

Apply strategy when only manual offset management is turned on

%i[
  manual_offset_management
].freeze

Instance Method Summary collapse

Methods included from Default

#commit_offsets, #commit_offsets!, #handle_before_consume, #handle_before_enqueue, #handle_consume, #handle_idle, #handle_revoked, #handle_shutdown, #mark_as_consumed, #mark_as_consumed!

Methods included from Base

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

Instance Method Details

#handle_after_consume ⇒ Object

When manual offset management is on, we do not mark anything as consumed automatically and we rely on the user to figure things out



17
18
19
20
21
22
23
24
25
 
# File 'lib/karafka/processing/strategies/mom.rb', line 17

def handle_after_consume
  return if revoked?

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