Module: Karafka::Processing::Jobs

Defined in:
lib/karafka/processing/jobs/base.rb,
lib/karafka/processing/jobs/idle.rb,
lib/karafka/processing/jobs/consume.rb,
lib/karafka/processing/jobs/revoked.rb,
lib/karafka/processing/jobs/shutdown.rb

Overview

Namespace for all the jobs that are supposed to run in workers.

Defined Under Namespace

Classes: Base, Consume, Idle, Revoked, Shutdown