Sha256: 7e2ddcbb18c88f9761943988cd70a4bf82e528b448adfa3391a3f3477a2ff829
Contents?: true
Size: 561 Bytes
Versions: 88
Compression:
Stored size: 561 Bytes
Contents
# frozen_string_literal: true module Karafka module Processing module Jobs # Job that runs the revoked operation when we loose a partition on a consumer that lost it. class Revoked < Base # @param executor [Karafka::Processing::Executor] executor that is suppose to run the job # @return [Revoked] def initialize(executor) @executor = executor super() end # Runs the revoking job via an executor. def call executor.revoked end end end end end
Version data entries
88 entries across 88 versions & 1 rubygems