Module: Karafka::Processing::ConsumerGroups

Defined in:

lib/karafka/processing/consumer_groups/executor.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

Consumer-group-specific processing components (driven by rebalance callbacks and partition ticks). Parallel ‘ShareGroups` will live next to this namespace once KIP-932 lands.

Defined Under Namespace

Modules: InlineInsights, Jobs, Strategies Classes: Coordinator, CoordinatorsBuffer, Executor, ExecutorsBuffer, ExpansionsSelector, JobsBuilder, Partitioner, StrategySelector