Module: Karafka::Pro::Processing::Strategies::Dlq::Vp

Includes:

Default, Vp::Default

Included in:

Aj::DlqMomVp, FtrLrjMomVp, FtrLrjVp, FtrMomVp, FtrVp, LrjMomVp, LrjVp, MomVp

Defined in:

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

Overview

Dead Letter Queue enabled Virtual Partitions enabled

In general because we collapse processing in virtual partitions to one on errors, there is no special action that needs to be taken because we warranty that even with VPs on errors a retry collapses into a single state and from this single state we can mark as consumed the message that we are moving to the DLQ.

Constant Summary

FEATURES =

Features for this strategy

%i[
  dead_letter_queue
  virtual_partitions
].freeze

Method Summary

Methods included from Vp::Default

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

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 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