Module: Karafka::Pro

Defined in:

lib/karafka/pro.rb,
lib/karafka/pro/loader.rb,
lib/karafka/pro/encryption.rb,
lib/karafka/pro/base_consumer.rb,
lib/karafka/pro/encryption/cipher.rb,
lib/karafka/pro/encryption/errors.rb,
lib/karafka/pro/active_job/consumer.rb,
lib/karafka/pro/performance_tracker.rb,
lib/karafka/pro/processing/scheduler.rb,
lib/karafka/pro/active_job/dispatcher.rb,
lib/karafka/pro/routing/features/base.rb,
lib/karafka/pro/processing/coordinator.rb,
lib/karafka/pro/processing/partitioner.rb,
lib/karafka/pro/encryption/setup/config.rb,
lib/karafka/pro/processing/jobs_builder.rb,
lib/karafka/pro/processing/strategies/vp.rb,
lib/karafka/pro/processing/strategies/dlq.rb,
lib/karafka/pro/processing/strategies/lrj.rb,
lib/karafka/pro/processing/strategies/mom.rb,
lib/karafka/pro/encryption/messages/parser.rb,
lib/karafka/pro/processing/strategies/base.rb,
lib/karafka/pro/encryption/contracts/config.rb,
lib/karafka/pro/processing/strategies/aj_mom.rb,
lib/karafka/pro/processing/strategies/lrj_vp.rb,
lib/karafka/pro/processing/strategy_selector.rb,
lib/karafka/pro/processing/strategies/default.rb,
lib/karafka/pro/processing/strategies/dlq_lrj.rb,
lib/karafka/pro/processing/strategies/dlq_mom.rb,
lib/karafka/pro/processing/strategies/lrj_mom.rb,
lib/karafka/pro/encryption/messages/middleware.rb,
lib/karafka/pro/active_job/job_options_contract.rb,
lib/karafka/pro/processing/strategies/aj_mom_vp.rb,
lib/karafka/pro/processing/strategies/aj_dlq_mom.rb,
lib/karafka/pro/processing/strategies/aj_lrj_mom.rb,
lib/karafka/pro/processing/strategies/dlq_lrj_mom.rb,
lib/karafka/pro/routing/features/long_running_job.rb,
lib/karafka/pro/routing/features/dead_letter_queue.rb,
lib/karafka/pro/processing/strategies/aj_lrj_mom_vp.rb,
lib/karafka/pro/routing/features/virtual_partitions.rb,
lib/karafka/pro/processing/jobs/consume_non_blocking.rb,
lib/karafka/pro/processing/jobs/revoked_non_blocking.rb,
lib/karafka/pro/processing/strategies/aj_dlq_lrj_mom.rb,
lib/karafka/pro/routing/features/long_running_job/topic.rb,
lib/karafka/pro/routing/features/long_running_job/config.rb,
lib/karafka/pro/routing/features/virtual_partitions/topic.rb,
lib/karafka/pro/routing/features/long_running_job/contract.rb,
lib/karafka/pro/routing/features/virtual_partitions/config.rb,
lib/karafka/pro/routing/features/dead_letter_queue/contract.rb,
lib/karafka/pro/routing/features/virtual_partitions/contract.rb

Overview

Namespace for pro components, licensed under the commercial license agreement.

Defined Under Namespace

Modules: ActiveJob, Encryption, Processing, Routing Classes: BaseConsumer, Loader, PerformanceTracker