Module: Karafka::Pro::Processing::Strategies::Dlq::FtrVp

Includes:

Ftr, Vp, Vp::Default

Defined in:

lib/karafka/pro/processing/strategies/dlq/ftr_vp.rb

Overview

• DLQ

• Ftr

• VPs

Behaves same as non-VP due to coordinator lock

Constant Summary

FEATURES =

Features for this strategy

%i[
  dead_letter_queue
  filtering
  virtual_partitions
].freeze

Method Summary

Methods included from Ftr

#handle_after_consume

Methods included from Default

#apply_dlq_flow, #build_dlq_message, #dispatch_if_needed_and_mark_as_consumed, #dispatch_in_a_transaction?, #dispatch_to_dlq, #dispatch_to_dlq?, #find_skippable_message, #handle_after_consume, #mark_after_dispatch?, #mark_as_consumed, #mark_as_consumed!, #mark_dispatched_to_dlq

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

#handle_after_consume, #handle_before_consume, #handle_before_schedule_consume, #handle_before_schedule_tick, #handle_consume, #handle_revoked, #handle_tick, #mark_as_consumed, #mark_as_consumed!, #mark_in_transaction, #store_offset_metadata, #transaction

Methods included from Karafka::Processing::Strategies::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 Karafka::Processing::Strategies::Base

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

Methods included from Ftr::Default

#handle_after_consume, #handle_idle, #handle_post_filtering

Methods included from Vp::Default

#collapse_until!, #collapsed?, #failing?, #mark_as_consumed, #mark_as_consumed!, #mark_in_transaction, #synchronize