Module: Karafka::Pro::Processing::Strategies::Mom::Ftr
- Includes:
- Ftr::Default, Default
- Included in:
- Aj::FtrMom, FtrVp
- Defined in:
- lib/karafka/pro/processing/strategies/mom/ftr.rb
Overview
Filtering support for MoM
Constant Summary collapse
- FEATURES =
MoM + Ftr
%i[ filtering manual_offset_management ].freeze
Instance Method Summary collapse
-
#handle_after_consume ⇒ Object
When mom is enabled, we do not mark messages as consumed after processing but we also need to keep in mind throttling here.
Methods included from Default
#handle_before_consume, #handle_before_enqueue, #handle_consume, #handle_revoked
Methods included from Karafka::Processing::Strategies::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 Karafka::Processing::Strategies::Base
#handle_before_consume, #handle_before_enqueue, #handle_consume, #handle_idle, #handle_revoked, #handle_shutdown
Methods included from Ftr::Default
#handle_idle, #handle_post_filtering
Instance Method Details
#handle_after_consume ⇒ Object
When mom is enabled, we do not mark messages as consumed after processing but we also need to keep in mind throttling here
32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 |
# File 'lib/karafka/pro/processing/strategies/mom/ftr.rb', line 32 def handle_after_consume coordinator.on_finished do return if revoked? if coordinator.success? coordinator.pause_tracker.reset # Do not throttle if paused return if coordinator.manual_pause? handle_post_filtering else retry_after_pause end end end |