Class: Karafka::Processing::Jobs::Revoked
- Defined in:
- lib/karafka/processing/jobs/revoked.rb
Overview
Job that runs the revoked operation when we loose a partition on a consumer that lost it.
Direct Known Subclasses
Instance Attribute Summary
Attributes inherited from Base
Instance Method Summary collapse
-
#call ⇒ Object
Runs the revoking job via an executor.
- #initialize(executor) ⇒ Revoked constructor
Methods inherited from Base
#after_call, #before_call, #before_enqueue, #non_blocking?
Constructor Details
#initialize(executor) ⇒ Revoked
10 11 12 13 |
# File 'lib/karafka/processing/jobs/revoked.rb', line 10 def initialize(executor) @executor = executor super() end |
Instance Method Details
#call ⇒ Object
Runs the revoking job via an executor.
16 17 18 |
# File 'lib/karafka/processing/jobs/revoked.rb', line 16 def call executor.revoked end |