Module: Karafka::Pro::Processing::Strategies::Dlq::FtrMomVp
Overview
-
DLQ
-
Ftr
-
Mom
-
VP
We can use the ‘Strategies::FtrMom` because VPs collapse prior to DLQ
Constant Summary collapse
- FEATURES =
Features for this strategy
%i[ dead_letter_queue filtering manual_offset_management virtual_partitions ].freeze
Method Summary
Methods included from FtrMom
Methods included from Default
#build_dlq_message, #dispatch_to_dlq, #dispatch_to_dlq?, #find_skippable_message, #handle_after_consume
Methods included from Karafka::Pro::Processing::Strategies::Default
#handle_after_consume, #handle_before_consume, #handle_before_enqueue, #handle_consume, #handle_revoked
Methods included from Karafka::Processing::Strategies::Default
#commit_offsets, #commit_offsets!, #handle_after_consume, #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_after_consume, #handle_before_consume, #handle_before_enqueue, #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
#collapsed?, #failing?, #mark_as_consumed, #mark_as_consumed!