Module: Karafka::Pro::Routing::Features::ConsumerGroups

Defined in:

lib/karafka/pro/routing/features/consumer_groups.rb,
lib/karafka/pro/routing/features/consumer_groups/swarm.rb,
lib/karafka/pro/routing/features/consumer_groups/delaying.rb,
lib/karafka/pro/routing/features/consumer_groups/patterns.rb,
lib/karafka/pro/routing/features/consumer_groups/active_job.rb,
lib/karafka/pro/routing/features/consumer_groups/swarm/topic.rb,
lib/karafka/pro/routing/features/consumer_groups/multiplexing.rb,
lib/karafka/pro/routing/features/consumer_groups/periodic_job.rb,
lib/karafka/pro/routing/features/consumer_groups/swarm/config.rb,
lib/karafka/pro/routing/features/consumer_groups/delaying/topic.rb,
lib/karafka/pro/routing/features/consumer_groups/patterns/topic.rb,
lib/karafka/pro/routing/features/consumer_groups/delaying/config.rb,
lib/karafka/pro/routing/features/consumer_groups/inline_insights.rb,
lib/karafka/pro/routing/features/consumer_groups/offset_metadata.rb,
lib/karafka/pro/routing/features/consumer_groups/patterns/config.rb,
lib/karafka/pro/routing/features/consumer_groups/patterns/topics.rb,
lib/karafka/pro/routing/features/consumer_groups/recurring_tasks.rb,
lib/karafka/pro/routing/features/consumer_groups/long_running_job.rb,
lib/karafka/pro/routing/features/consumer_groups/non_blocking_job.rb,
lib/karafka/pro/routing/features/consumer_groups/patterns/builder.rb,
lib/karafka/pro/routing/features/consumer_groups/patterns/pattern.rb,
lib/karafka/pro/routing/features/consumer_groups/adaptive_iterator.rb,
lib/karafka/pro/routing/features/consumer_groups/dead_letter_queue.rb,
lib/karafka/pro/routing/features/consumer_groups/parallel_segments.rb,
lib/karafka/pro/routing/features/consumer_groups/patterns/detector.rb,
lib/karafka/pro/routing/features/consumer_groups/patterns/patterns.rb,
lib/karafka/pro/routing/features/consumer_groups/active_job/builder.rb,
lib/karafka/pro/routing/features/consumer_groups/direct_assignments.rb,
lib/karafka/pro/routing/features/consumer_groups/multiplexing/proxy.rb,
lib/karafka/pro/routing/features/consumer_groups/periodic_job/topic.rb,
lib/karafka/pro/routing/features/consumer_groups/scheduled_messages.rb,
lib/karafka/pro/routing/features/consumer_groups/virtual_partitions.rb,
lib/karafka/pro/routing/features/consumer_groups/multiplexing/config.rb,
lib/karafka/pro/routing/features/consumer_groups/periodic_job/config.rb,
lib/karafka/pro/routing/features/consumer_groups/inline_insights/topic.rb,
lib/karafka/pro/routing/features/consumer_groups/offset_metadata/topic.rb,
lib/karafka/pro/routing/features/consumer_groups/recurring_tasks/proxy.rb,
lib/karafka/pro/routing/features/consumer_groups/recurring_tasks/topic.rb,
lib/karafka/pro/routing/features/consumer_groups/swarm/contracts/topic.rb,
lib/karafka/pro/routing/features/consumer_groups/inline_insights/config.rb,
lib/karafka/pro/routing/features/consumer_groups/long_running_job/topic.rb,
lib/karafka/pro/routing/features/consumer_groups/non_blocking_job/topic.rb,
lib/karafka/pro/routing/features/consumer_groups/offset_metadata/config.rb,
lib/karafka/pro/routing/features/consumer_groups/recurring_tasks/config.rb,
lib/karafka/pro/routing/features/consumer_groups/adaptive_iterator/topic.rb,
lib/karafka/pro/routing/features/consumer_groups/dead_letter_queue/topic.rb,
lib/karafka/pro/routing/features/consumer_groups/long_running_job/config.rb,
lib/karafka/pro/routing/features/consumer_groups/parallel_segments/topic.rb,
lib/karafka/pro/routing/features/consumer_groups/patterns/consumer_group.rb,
lib/karafka/pro/routing/features/consumer_groups/recurring_tasks/builder.rb,
lib/karafka/pro/routing/features/consumer_groups/swarm/contracts/routing.rb,
lib/karafka/pro/routing/features/consumer_groups/adaptive_iterator/config.rb,
lib/karafka/pro/routing/features/consumer_groups/delaying/contracts/topic.rb,
lib/karafka/pro/routing/features/consumer_groups/direct_assignments/topic.rb,
lib/karafka/pro/routing/features/consumer_groups/parallel_segments/config.rb,
lib/karafka/pro/routing/features/consumer_groups/patterns/contracts/topic.rb,
lib/karafka/pro/routing/features/consumer_groups/scheduled_messages/proxy.rb,
lib/karafka/pro/routing/features/consumer_groups/scheduled_messages/topic.rb,
lib/karafka/pro/routing/features/consumer_groups/virtual_partitions/topic.rb,
lib/karafka/pro/routing/features/consumer_groups/direct_assignments/config.rb,
lib/karafka/pro/routing/features/consumer_groups/parallel_segments/builder.rb,
lib/karafka/pro/routing/features/consumer_groups/scheduled_messages/config.rb,
lib/karafka/pro/routing/features/consumer_groups/virtual_partitions/config.rb,
lib/karafka/pro/routing/features/consumer_groups/patterns/contracts/pattern.rb,
lib/karafka/pro/routing/features/consumer_groups/scheduled_messages/builder.rb,
lib/karafka/pro/routing/features/consumer_groups/multiplexing/contracts/topic.rb,
lib/karafka/pro/routing/features/consumer_groups/periodic_job/contracts/topic.rb,
lib/karafka/pro/routing/features/consumer_groups/multiplexing/contracts/routing.rb,
lib/karafka/pro/routing/features/consumer_groups/inline_insights/contracts/topic.rb,
lib/karafka/pro/routing/features/consumer_groups/multiplexing/subscription_group.rb,
lib/karafka/pro/routing/features/consumer_groups/offset_metadata/contracts/topic.rb,
lib/karafka/pro/routing/features/consumer_groups/recurring_tasks/contracts/topic.rb,
lib/karafka/pro/routing/features/consumer_groups/long_running_job/contracts/topic.rb,
lib/karafka/pro/routing/features/consumer_groups/parallel_segments/consumer_group.rb,
lib/karafka/pro/routing/features/consumer_groups/adaptive_iterator/contracts/topic.rb,
lib/karafka/pro/routing/features/consumer_groups/dead_letter_queue/contracts/topic.rb,
lib/karafka/pro/routing/features/consumer_groups/patterns/contracts/consumer_group.rb,
lib/karafka/pro/routing/features/consumer_groups/direct_assignments/contracts/topic.rb,
lib/karafka/pro/routing/features/consumer_groups/scheduled_messages/contracts/topic.rb,
lib/karafka/pro/routing/features/consumer_groups/virtual_partitions/contracts/topic.rb,
lib/karafka/pro/routing/features/consumer_groups/direct_assignments/subscription_group.rb,
lib/karafka/pro/routing/features/consumer_groups/multiplexing/subscription_groups_builder.rb,
lib/karafka/pro/routing/features/consumer_groups/parallel_segments/contracts/consumer_group.rb,
lib/karafka/pro/routing/features/consumer_groups/direct_assignments/contracts/consumer_group.rb,
lib/karafka/pro/routing/features/consumer_groups/multiplexing/patches/contracts/consumer_group.rb

Overview

Consumer-group-specific Pro routing features. A parallel ‘ShareGroups` namespace will hold share-group-specific feature implementations once KIP-932 lands.

Defined Under Namespace

Classes: ActiveJob, AdaptiveIterator, DeadLetterQueue, Delaying, DirectAssignments, InlineInsights, LongRunningJob, Multiplexing, NonBlockingJob, OffsetMetadata, ParallelSegments, Patterns, PeriodicJob, RecurringTasks, ScheduledMessages, Swarm, VirtualPartitions