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_consume, #handle_eofed, #handle_idle, #handle_initialized, #handle_revoked, #handle_shutdown, #handle_wrap, #mark_as_consumed, #mark_as_consumed!

Methods included from Base

#handle_before_consume, #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

[View source]

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