Module: Karafka::Processing

Defined in:
lib/karafka/processing/consumer_groups/executor.rb,
lib/karafka/processing/result.rb,
lib/karafka/processing/worker.rb,
lib/karafka/processing/jobs/base.rb,
lib/karafka/processing/jobs_queue.rb,
lib/karafka/processing/coordinator.rb,
lib/karafka/processing/partitioner.rb,
lib/karafka/processing/workers_pool.rb,
lib/karafka/processing/strategy_selector.rb,
lib/karafka/processing/schedulers/default.rb,
lib/karafka/processing/coordinators_buffer.rb,
lib/karafka/processing/consumer_groups/jobs/idle.rb,
lib/karafka/processing/consumer_groups/jobs/eofed.rb,
lib/karafka/processing/consumer_groups/coordinator.rb,
lib/karafka/processing/consumer_groups/partitioner.rb,
lib/karafka/processing/consumer_groups/jobs/consume.rb,
lib/karafka/processing/consumer_groups/jobs/revoked.rb,
lib/karafka/processing/consumer_groups/jobs_builder.rb,
lib/karafka/processing/consumer_groups/jobs/shutdown.rb,
lib/karafka/processing/consumer_groups/strategies/dlq.rb,
lib/karafka/processing/consumer_groups/strategies/mom.rb,
lib/karafka/processing/consumer_groups/strategies/base.rb,
lib/karafka/processing/consumer_groups/executors_buffer.rb,
lib/karafka/processing/consumer_groups/strategies/aj_mom.rb,
lib/karafka/processing/consumer_groups/strategy_selector.rb,
lib/karafka/processing/consumer_groups/strategies/default.rb,
lib/karafka/processing/consumer_groups/strategies/dlq_mom.rb,
lib/karafka/processing/consumer_groups/coordinators_buffer.rb,
lib/karafka/processing/consumer_groups/expansions_selector.rb,
lib/karafka/processing/consumer_groups/strategies/aj_dlq_mom.rb,
lib/karafka/processing/consumer_groups/inline_insights/tracker.rb,
lib/karafka/processing/consumer_groups/inline_insights/consumer.rb,
lib/karafka/processing/consumer_groups/inline_insights/listener.rb

Overview

Namespace that encapsulates all the logic related to processing data.

Defined Under Namespace

Modules: ConsumerGroups, Jobs, Schedulers Classes: JobsQueue, Result, Worker, WorkersPool

Constant Summary collapse

Coordinator =

See Also:

ConsumerGroups::Coordinator
Partitioner =

See Also:

ConsumerGroups::Partitioner
StrategySelector =

See Also:

ConsumerGroups::StrategySelector
CoordinatorsBuffer =

See Also:

ConsumerGroups::CoordinatorsBuffer