Module: Karafka::Pro::Processing::Strategies::LrjVp

Includes:

Lrj

Defined in:

lib/karafka/pro/processing/strategies/lrj_vp.rb

Overview

Long-Running Job enabled Virtual Partitions enabled

Constant Summary

FEATURES =

Features for this strategy

%i[
  long_running_job
  virtual_partitions
].freeze

Constants included from Lrj

Karafka::Pro::Processing::Strategies::Lrj::MAX_PAUSE_TIME

Method Summary

Methods included from Lrj

#handle_after_consume, #handle_before_enqueue, #handle_revoked

Methods included from Default

#handle_after_consume, #handle_before_consume, #handle_before_enqueue, #handle_consume, #handle_revoked

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

#handle_after_consume, #handle_before_consume, #handle_before_enqueue, #handle_consume, #handle_revoked, #handle_shutdown

Methods included from Karafka::Processing::Strategies::Base

#handle_after_consume, #handle_before_consume, #handle_before_enqueue, #handle_consume, #handle_revoked, #handle_shutdown