Module: Karafka::Pro::Processing::Strategies::Ftr::Vp

Includes:

Default, Vp::Default

Defined in:

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

Overview

Filtering enabled VPs enabled

VPs should operate without any problems with filtering because virtual partitioning happens on the limited set of messages and collective filtering applies the same way as for default cases

Constant Summary

FEATURES =

Filtering + VPs

%i[
  filtering
  virtual_partitions
].freeze

Method Summary

Methods included from Default

#handle_after_consume, #handle_idle, #handle_post_filtering

Methods included from 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 Vp::Default

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