Class: Karafka::Pro::Processing::Jobs::RevokedNonBlocking

Inherits:
Karafka::Processing::Jobs::Revoked show all
Defined in:
lib/karafka/pro/processing/jobs/revoked_non_blocking.rb

Overview

The revoked job type in a non-blocking variant. This variant works “like” the regular revoked but does not block the queue.

It can be useful when having long lasting jobs that would exceed ‘max.poll.interval` in scenarios where there are more jobs than threads, without this being async we would potentially stop polling

Instance Attribute Summary

Attributes inherited from Karafka::Processing::Jobs::Base

#executor

Instance Method Summary collapse

Methods inherited from Karafka::Processing::Jobs::Revoked

#before_schedule, #call

Methods inherited from Karafka::Processing::Jobs::Base

#after_call, #before_call, #before_schedule, #call, #finish!, #finished?, #non_blocking?, #wrap

Constructor Details

#initialize(*args) ⇒ RevokedNonBlocking

Makes this job non-blocking from the start

Parameters:

  • args (Array) —

    any arguments accepted by ‘::Karafka::Processing::Jobs::Revoked`



31
32
33
34
 
# File 'lib/karafka/pro/processing/jobs/revoked_non_blocking.rb', line 31

def initialize(*args)
  super
  @non_blocking = true
end