Class: Karafka::Pro::Processing::JobsBuilder

Inherits:
Karafka::Processing::JobsBuilder show all
Defined in:
lib/karafka/pro/processing/jobs_builder.rb

Overview

Pro jobs builder that supports lrj

Instance Method Summary collapse

Methods inherited from Karafka::Processing::JobsBuilder

#shutdown

Instance Method Details

#consume(executor, messages, coordinator) ⇒ Karafka::Processing::Jobs::Consume, Karafka::Pro::Processing::Jobs::ConsumeNonBlocking

Parameters:

Returns:



24
25
26
27
28
29
30
 
# File 'lib/karafka/pro/processing/jobs_builder.rb', line 24

def consume(executor, messages, coordinator)
  if executor.topic.long_running_job?
    Jobs::ConsumeNonBlocking.new(executor, messages, coordinator)
  else
    super
  end
end

#revoked(executor) ⇒ Karafka::Processing::Jobs::Revoked, Karafka::Processing::Jobs::RevokedNonBlocking

Parameters:

Returns:

  • (Karafka::Processing::Jobs::Revoked) —

    revocation job for non LRJ

  • (Karafka::Processing::Jobs::RevokedNonBlocking) —

    revocation job that is non-blocking, so when revocation job is scheduled for LRJ it also will not block



36
37
38
39
40
41
42
 
# File 'lib/karafka/pro/processing/jobs_builder.rb', line 36

def revoked(executor)
  if executor.topic.long_running_job?
    Jobs::RevokedNonBlocking.new(executor)
  else
    super
  end
end