# -*- encoding: utf-8 -*-
# stub: karafka 2.4.12 ruby lib

Gem::Specification.new do |s|
  s.name = "karafka".freeze
  s.version = "2.4.12".freeze

  s.required_rubygems_version = Gem::Requirement.new(">= 0".freeze) if s.respond_to? :required_rubygems_version=
  s.metadata = { "bug_tracker_uri" => "https://github.com/karafka/karafka/issues", "changelog_uri" => "https://karafka.io/docs/Changelog-Karafka", "documentation_uri" => "https://karafka.io/docs", "funding_uri" => "https://karafka.io/#become-pro", "homepage_uri" => "https://karafka.io", "rubygems_mfa_required" => "true", "source_code_uri" => "https://github.com/karafka/karafka" } if s.respond_to? :metadata=
  s.require_paths = ["lib".freeze]
  s.authors = ["Maciej Mensfeld".freeze]
  s.cert_chain = ["-----BEGIN CERTIFICATE-----\nMIIEcDCCAtigAwIBAgIBATANBgkqhkiG9w0BAQsFADA/MRAwDgYDVQQDDAdjb250\nYWN0MRcwFQYKCZImiZPyLGQBGRYHa2FyYWZrYTESMBAGCgmSJomT8ixkARkWAmlv\nMB4XDTI0MDgyMzEwMTkyMFoXDTQ5MDgxNzEwMTkyMFowPzEQMA4GA1UEAwwHY29u\ndGFjdDEXMBUGCgmSJomT8ixkARkWB2thcmFma2ExEjAQBgoJkiaJk/IsZAEZFgJp\nbzCCAaIwDQYJKoZIhvcNAQEBBQADggGPADCCAYoCggGBAKjLhLjQqUlNayxkXnO+\nPsmCDs/KFIzhrsYMfLZRZNaWmzV3ujljMOdDjd4snM2X06C41iVdQPWjpe3j8vVe\nZXEWR/twSbOP6Eeg8WVH2wCOo0x5i7yhVn4UBLH4JpfEMCbemVcWQ9ry9OMg4WpH\nUu4dRwxFV7hzCz3p0QfNLRI4miAxnGWcnlD98IJRjBAksTuR1Llj0vbOrDGsL9ZT\nJeXP2gdRLd8SqzAFJEWrbeTBCBU7gfSh3oMg5SVDLjaqf7Kz5wC/8bDZydzanOxB\nT6CDXPsCnllmvTNx2ei2T5rGYJOzJeNTmJLLK6hJWUlAvaQSvCwZRvFJ0tVGLEoS\nflqSr6uGyyl1eMUsNmsH4BqPEYcAV6P2PKTv2vUR8AP0raDvZ3xL1TKvfRb8xRpo\nvPopCGlY5XBWEc6QERHfVLTIVsjnls2/Ujj4h8/TSfqqYnaHKefIMLbuD/tquMjD\niWQsW2qStBV0T+U7FijKxVfrfqZP7GxQmDAc9o1iiyAa3QIDAQABo3cwdTAJBgNV\nHRMEAjAAMAsGA1UdDwQEAwIEsDAdBgNVHQ4EFgQU3O4dTXmvE7YpAkszGzR9DdL9\nsbEwHQYDVR0RBBYwFIESY29udGFjdEBrYXJhZmthLmlvMB0GA1UdEgQWMBSBEmNv\nbnRhY3RAa2FyYWZrYS5pbzANBgkqhkiG9w0BAQsFAAOCAYEAVKTfoLXn7mqdSxIR\neqxcR6Huudg1jes81s1+X0uiRTR3hxxKZ3Y82cPsee9zYWyBrN8TA4KA0WILTru7\nYgxvzha0SRPsSiaKLmgOJ+61ebI4+bOORzIJLpD6GxCxu1r7MI4+0r1u1xe0EWi8\nagkVo1k4Vi8cKMLm6Gl9b3wG9zQBw6fcgKwmpjKiNnOLP+OytzUANrIUJjoq6oal\nTC+f/Uc0TLaRqUaW/bejxzDWWHoM3SU6aoLPuerglzp9zZVzihXwx3jPLUVKDFpF\nRl2lcBDxlpYGueGo0/oNzGJAAy6js8jhtHC9+19PD53vk7wHtFTZ/0ugDQYnwQ+x\noml2fAAuVWpTBCgOVFe6XCQpMKopzoxQ1PjKztW2KYxgJdIBX87SnL3aWuBQmhRd\ni9zWxov0mr44TWegTVeypcWGd/0nxu1+QHVNHJrpqlPBRvwQsUm7fwmRInGpcaB8\nap8wNYvryYzrzvzUxIVFBVM5PacgkFqRmolCa8I7tdKQN+R1\n-----END CERTIFICATE-----\n".freeze]
  s.date = "2024-09-17"
  s.description = "    Karafka is Ruby and Rails efficient Kafka processing framework.\n\n    Karafka allows you to capture everything that happens in your systems in large scale,\n    without having to focus on things that are not your business domain.\n".freeze
  s.email = ["contact@karafka.io".freeze]
  s.executables = ["karafka".freeze]
  s.files = [".coditsu/ci.yml".freeze, ".console_irbrc".freeze, ".diffend.yml".freeze, ".github/FUNDING.yml".freeze, ".github/ISSUE_TEMPLATE/bug_report.md".freeze, ".github/ISSUE_TEMPLATE/feature_request.md".freeze, ".github/workflows/ci.yml".freeze, ".gitignore".freeze, ".rspec".freeze, ".ruby-gemset".freeze, ".ruby-version".freeze, "CHANGELOG.md".freeze, "CODE_OF_CONDUCT.md".freeze, "CONTRIBUTING.md".freeze, "Gemfile".freeze, "Gemfile.lock".freeze, "LICENSE".freeze, "LICENSE-COMM".freeze, "LICENSE-LGPL".freeze, "README.md".freeze, "SECURITY.md".freeze, "bin/benchmarks".freeze, "bin/create_token".freeze, "bin/integrations".freeze, "bin/karafka".freeze, "bin/record_rss".freeze, "bin/rspecs".freeze, "bin/scenario".freeze, "bin/stress_many".freeze, "bin/stress_one".freeze, "bin/verify_license_integrity".freeze, "bin/wait_for_kafka".freeze, "certs/cert.pem".freeze, "certs/karafka-pro.pem".freeze, "config/locales/errors.yml".freeze, "config/locales/pro_errors.yml".freeze, "docker-compose.yml".freeze, "karafka.gemspec".freeze, "lib/active_job/karafka.rb".freeze, "lib/active_job/queue_adapters/karafka_adapter.rb".freeze, "lib/karafka.rb".freeze, "lib/karafka/active_job/consumer.rb".freeze, "lib/karafka/active_job/current_attributes.rb".freeze, "lib/karafka/active_job/current_attributes/loading.rb".freeze, "lib/karafka/active_job/current_attributes/persistence.rb".freeze, "lib/karafka/active_job/dispatcher.rb".freeze, "lib/karafka/active_job/job_extensions.rb".freeze, "lib/karafka/active_job/job_options_contract.rb".freeze, "lib/karafka/admin.rb".freeze, "lib/karafka/admin/acl.rb".freeze, "lib/karafka/admin/configs.rb".freeze, "lib/karafka/admin/configs/config.rb".freeze, "lib/karafka/admin/configs/resource.rb".freeze, "lib/karafka/app.rb".freeze, "lib/karafka/base_consumer.rb".freeze, "lib/karafka/cli.rb".freeze, "lib/karafka/cli/base.rb".freeze, "lib/karafka/cli/console.rb".freeze, "lib/karafka/cli/help.rb".freeze, "lib/karafka/cli/info.rb".freeze, "lib/karafka/cli/install.rb".freeze, "lib/karafka/cli/server.rb".freeze, "lib/karafka/cli/swarm.rb".freeze, "lib/karafka/cli/topics.rb".freeze, "lib/karafka/cli/topics/align.rb".freeze, "lib/karafka/cli/topics/base.rb".freeze, "lib/karafka/cli/topics/create.rb".freeze, "lib/karafka/cli/topics/delete.rb".freeze, "lib/karafka/cli/topics/migrate.rb".freeze, "lib/karafka/cli/topics/plan.rb".freeze, "lib/karafka/cli/topics/repartition.rb".freeze, "lib/karafka/cli/topics/reset.rb".freeze, "lib/karafka/connection/client.rb".freeze, "lib/karafka/connection/conductor.rb".freeze, "lib/karafka/connection/listener.rb".freeze, "lib/karafka/connection/listeners_batch.rb".freeze, "lib/karafka/connection/manager.rb".freeze, "lib/karafka/connection/messages_buffer.rb".freeze, "lib/karafka/connection/pauses_manager.rb".freeze, "lib/karafka/connection/proxy.rb".freeze, "lib/karafka/connection/raw_messages_buffer.rb".freeze, "lib/karafka/connection/rebalance_manager.rb".freeze, "lib/karafka/connection/status.rb".freeze, "lib/karafka/constraints.rb".freeze, "lib/karafka/contracts.rb".freeze, "lib/karafka/contracts/base.rb".freeze, "lib/karafka/contracts/config.rb".freeze, "lib/karafka/contracts/consumer_group.rb".freeze, "lib/karafka/contracts/server_cli_options.rb".freeze, "lib/karafka/contracts/topic.rb".freeze, "lib/karafka/deserializers/headers.rb".freeze, "lib/karafka/deserializers/key.rb".freeze, "lib/karafka/deserializers/payload.rb".freeze, "lib/karafka/embedded.rb".freeze, "lib/karafka/env.rb".freeze, "lib/karafka/errors.rb".freeze, "lib/karafka/helpers/async.rb".freeze, "lib/karafka/helpers/colorize.rb".freeze, "lib/karafka/helpers/config_importer.rb".freeze, "lib/karafka/helpers/interval_runner.rb".freeze, "lib/karafka/helpers/multi_delegator.rb".freeze, "lib/karafka/instrumentation/assignments_tracker.rb".freeze, "lib/karafka/instrumentation/callbacks/error.rb".freeze, "lib/karafka/instrumentation/callbacks/oauthbearer_token_refresh.rb".freeze, "lib/karafka/instrumentation/callbacks/rebalance.rb".freeze, "lib/karafka/instrumentation/callbacks/statistics.rb".freeze, "lib/karafka/instrumentation/logger.rb".freeze, "lib/karafka/instrumentation/logger_listener.rb".freeze, "lib/karafka/instrumentation/monitor.rb".freeze, "lib/karafka/instrumentation/notifications.rb".freeze, "lib/karafka/instrumentation/proctitle_listener.rb".freeze, "lib/karafka/instrumentation/vendors/appsignal/base.rb".freeze, "lib/karafka/instrumentation/vendors/appsignal/client.rb".freeze, "lib/karafka/instrumentation/vendors/appsignal/dashboard.json".freeze, "lib/karafka/instrumentation/vendors/appsignal/errors_listener.rb".freeze, "lib/karafka/instrumentation/vendors/appsignal/metrics_listener.rb".freeze, "lib/karafka/instrumentation/vendors/datadog/dashboard.json".freeze, "lib/karafka/instrumentation/vendors/datadog/logger_listener.rb".freeze, "lib/karafka/instrumentation/vendors/datadog/metrics_listener.rb".freeze, "lib/karafka/instrumentation/vendors/kubernetes/base_listener.rb".freeze, "lib/karafka/instrumentation/vendors/kubernetes/liveness_listener.rb".freeze, "lib/karafka/instrumentation/vendors/kubernetes/swarm_liveness_listener.rb".freeze, "lib/karafka/licenser.rb".freeze, "lib/karafka/messages/batch_metadata.rb".freeze, "lib/karafka/messages/builders/batch_metadata.rb".freeze, "lib/karafka/messages/builders/message.rb".freeze, "lib/karafka/messages/builders/messages.rb".freeze, "lib/karafka/messages/message.rb".freeze, "lib/karafka/messages/messages.rb".freeze, "lib/karafka/messages/metadata.rb".freeze, "lib/karafka/messages/parser.rb".freeze, "lib/karafka/messages/seek.rb".freeze, "lib/karafka/patches/rdkafka/bindings.rb".freeze, "lib/karafka/patches/rdkafka/opaque.rb".freeze, "lib/karafka/pro.rb".freeze, "lib/karafka/pro/active_job/consumer.rb".freeze, "lib/karafka/pro/active_job/dispatcher.rb".freeze, "lib/karafka/pro/active_job/job_options_contract.rb".freeze, "lib/karafka/pro/base_consumer.rb".freeze, "lib/karafka/pro/cleaner.rb".freeze, "lib/karafka/pro/cleaner/errors.rb".freeze, "lib/karafka/pro/cleaner/messages/message.rb".freeze, "lib/karafka/pro/cleaner/messages/messages.rb".freeze, "lib/karafka/pro/connection/manager.rb".freeze, "lib/karafka/pro/connection/multiplexing/listener.rb".freeze, "lib/karafka/pro/contracts/base.rb".freeze, "lib/karafka/pro/contracts/server_cli_options.rb".freeze, "lib/karafka/pro/encryption.rb".freeze, "lib/karafka/pro/encryption/cipher.rb".freeze, "lib/karafka/pro/encryption/contracts/config.rb".freeze, "lib/karafka/pro/encryption/errors.rb".freeze, "lib/karafka/pro/encryption/messages/middleware.rb".freeze, "lib/karafka/pro/encryption/messages/parser.rb".freeze, "lib/karafka/pro/encryption/setup/config.rb".freeze, "lib/karafka/pro/instrumentation/performance_tracker.rb".freeze, "lib/karafka/pro/iterator.rb".freeze, "lib/karafka/pro/iterator/expander.rb".freeze, "lib/karafka/pro/iterator/tpl_builder.rb".freeze, "lib/karafka/pro/loader.rb".freeze, "lib/karafka/pro/processing/adaptive_iterator/consumer.rb".freeze, "lib/karafka/pro/processing/adaptive_iterator/tracker.rb".freeze, "lib/karafka/pro/processing/collapser.rb".freeze, "lib/karafka/pro/processing/coordinator.rb".freeze, "lib/karafka/pro/processing/coordinators/errors_tracker.rb".freeze, "lib/karafka/pro/processing/coordinators/filters_applier.rb".freeze, "lib/karafka/pro/processing/coordinators/virtual_offset_manager.rb".freeze, "lib/karafka/pro/processing/executor.rb".freeze, "lib/karafka/pro/processing/expansions_selector.rb".freeze, "lib/karafka/pro/processing/filters/base.rb".freeze, "lib/karafka/pro/processing/filters/delayer.rb".freeze, "lib/karafka/pro/processing/filters/expirer.rb".freeze, "lib/karafka/pro/processing/filters/inline_insights_delayer.rb".freeze, "lib/karafka/pro/processing/filters/throttler.rb".freeze, "lib/karafka/pro/processing/filters/virtual_limiter.rb".freeze, "lib/karafka/pro/processing/jobs/consume_non_blocking.rb".freeze, "lib/karafka/pro/processing/jobs/eofed_non_blocking.rb".freeze, "lib/karafka/pro/processing/jobs/periodic.rb".freeze, "lib/karafka/pro/processing/jobs/periodic_non_blocking.rb".freeze, "lib/karafka/pro/processing/jobs/revoked_non_blocking.rb".freeze, "lib/karafka/pro/processing/jobs_builder.rb".freeze, "lib/karafka/pro/processing/jobs_queue.rb".freeze, "lib/karafka/pro/processing/offset_metadata/consumer.rb".freeze, "lib/karafka/pro/processing/offset_metadata/fetcher.rb".freeze, "lib/karafka/pro/processing/offset_metadata/listener.rb".freeze, "lib/karafka/pro/processing/partitioner.rb".freeze, "lib/karafka/pro/processing/periodic_job/consumer.rb".freeze, "lib/karafka/pro/processing/piping/consumer.rb".freeze, "lib/karafka/pro/processing/schedulers/base.rb".freeze, "lib/karafka/pro/processing/schedulers/default.rb".freeze, "lib/karafka/pro/processing/strategies.rb".freeze, "lib/karafka/pro/processing/strategies/aj/dlq_ftr_lrj_mom.rb".freeze, "lib/karafka/pro/processing/strategies/aj/dlq_ftr_lrj_mom_vp.rb".freeze, "lib/karafka/pro/processing/strategies/aj/dlq_ftr_mom.rb".freeze, "lib/karafka/pro/processing/strategies/aj/dlq_ftr_mom_vp.rb".freeze, "lib/karafka/pro/processing/strategies/aj/dlq_lrj_mom.rb".freeze, "lib/karafka/pro/processing/strategies/aj/dlq_lrj_mom_vp.rb".freeze, "lib/karafka/pro/processing/strategies/aj/dlq_mom.rb".freeze, "lib/karafka/pro/processing/strategies/aj/dlq_mom_vp.rb".freeze, "lib/karafka/pro/processing/strategies/aj/ftr_lrj_mom.rb".freeze, "lib/karafka/pro/processing/strategies/aj/ftr_lrj_mom_vp.rb".freeze, "lib/karafka/pro/processing/strategies/aj/ftr_mom.rb".freeze, "lib/karafka/pro/processing/strategies/aj/ftr_mom_vp.rb".freeze, "lib/karafka/pro/processing/strategies/aj/lrj_mom.rb".freeze, "lib/karafka/pro/processing/strategies/aj/lrj_mom_vp.rb".freeze, "lib/karafka/pro/processing/strategies/aj/mom.rb".freeze, "lib/karafka/pro/processing/strategies/aj/mom_vp.rb".freeze, "lib/karafka/pro/processing/strategies/base.rb".freeze, "lib/karafka/pro/processing/strategies/default.rb".freeze, "lib/karafka/pro/processing/strategies/dlq/default.rb".freeze, "lib/karafka/pro/processing/strategies/dlq/ftr.rb".freeze, "lib/karafka/pro/processing/strategies/dlq/ftr_lrj.rb".freeze, "lib/karafka/pro/processing/strategies/dlq/ftr_lrj_mom.rb".freeze, "lib/karafka/pro/processing/strategies/dlq/ftr_lrj_mom_vp.rb".freeze, "lib/karafka/pro/processing/strategies/dlq/ftr_lrj_vp.rb".freeze, "lib/karafka/pro/processing/strategies/dlq/ftr_mom.rb".freeze, "lib/karafka/pro/processing/strategies/dlq/ftr_mom_vp.rb".freeze, "lib/karafka/pro/processing/strategies/dlq/ftr_vp.rb".freeze, "lib/karafka/pro/processing/strategies/dlq/lrj.rb".freeze, "lib/karafka/pro/processing/strategies/dlq/lrj_mom.rb".freeze, "lib/karafka/pro/processing/strategies/dlq/lrj_mom_vp.rb".freeze, "lib/karafka/pro/processing/strategies/dlq/lrj_vp.rb".freeze, "lib/karafka/pro/processing/strategies/dlq/mom.rb".freeze, "lib/karafka/pro/processing/strategies/dlq/mom_vp.rb".freeze, "lib/karafka/pro/processing/strategies/dlq/vp.rb".freeze, "lib/karafka/pro/processing/strategies/ftr/default.rb".freeze, "lib/karafka/pro/processing/strategies/ftr/vp.rb".freeze, "lib/karafka/pro/processing/strategies/lrj/default.rb".freeze, "lib/karafka/pro/processing/strategies/lrj/ftr.rb".freeze, "lib/karafka/pro/processing/strategies/lrj/ftr_mom.rb".freeze, "lib/karafka/pro/processing/strategies/lrj/ftr_mom_vp.rb".freeze, "lib/karafka/pro/processing/strategies/lrj/ftr_vp.rb".freeze, "lib/karafka/pro/processing/strategies/lrj/mom.rb".freeze, "lib/karafka/pro/processing/strategies/lrj/mom_vp.rb".freeze, "lib/karafka/pro/processing/strategies/lrj/vp.rb".freeze, "lib/karafka/pro/processing/strategies/mom/default.rb".freeze, "lib/karafka/pro/processing/strategies/mom/ftr.rb".freeze, "lib/karafka/pro/processing/strategies/mom/ftr_vp.rb".freeze, "lib/karafka/pro/processing/strategies/mom/vp.rb".freeze, "lib/karafka/pro/processing/strategies/vp/default.rb".freeze, "lib/karafka/pro/processing/strategy_selector.rb".freeze, "lib/karafka/pro/processing/subscription_groups_coordinator.rb".freeze, "lib/karafka/pro/recurring_tasks.rb".freeze, "lib/karafka/pro/recurring_tasks/consumer.rb".freeze, "lib/karafka/pro/recurring_tasks/contracts/config.rb".freeze, "lib/karafka/pro/recurring_tasks/contracts/task.rb".freeze, "lib/karafka/pro/recurring_tasks/deserializer.rb".freeze, "lib/karafka/pro/recurring_tasks/dispatcher.rb".freeze, "lib/karafka/pro/recurring_tasks/errors.rb".freeze, "lib/karafka/pro/recurring_tasks/executor.rb".freeze, "lib/karafka/pro/recurring_tasks/listener.rb".freeze, "lib/karafka/pro/recurring_tasks/matcher.rb".freeze, "lib/karafka/pro/recurring_tasks/schedule.rb".freeze, "lib/karafka/pro/recurring_tasks/serializer.rb".freeze, "lib/karafka/pro/recurring_tasks/setup/config.rb".freeze, "lib/karafka/pro/recurring_tasks/task.rb".freeze, "lib/karafka/pro/routing/features/active_job.rb".freeze, "lib/karafka/pro/routing/features/active_job/builder.rb".freeze, "lib/karafka/pro/routing/features/adaptive_iterator.rb".freeze, "lib/karafka/pro/routing/features/adaptive_iterator/config.rb".freeze, "lib/karafka/pro/routing/features/adaptive_iterator/contracts/topic.rb".freeze, "lib/karafka/pro/routing/features/adaptive_iterator/topic.rb".freeze, "lib/karafka/pro/routing/features/base.rb".freeze, "lib/karafka/pro/routing/features/dead_letter_queue.rb".freeze, "lib/karafka/pro/routing/features/dead_letter_queue/contracts/topic.rb".freeze, "lib/karafka/pro/routing/features/dead_letter_queue/topic.rb".freeze, "lib/karafka/pro/routing/features/delaying.rb".freeze, "lib/karafka/pro/routing/features/delaying/config.rb".freeze, "lib/karafka/pro/routing/features/delaying/contracts/topic.rb".freeze, "lib/karafka/pro/routing/features/delaying/topic.rb".freeze, "lib/karafka/pro/routing/features/direct_assignments.rb".freeze, "lib/karafka/pro/routing/features/direct_assignments/config.rb".freeze, "lib/karafka/pro/routing/features/direct_assignments/contracts/consumer_group.rb".freeze, "lib/karafka/pro/routing/features/direct_assignments/contracts/topic.rb".freeze, "lib/karafka/pro/routing/features/direct_assignments/subscription_group.rb".freeze, "lib/karafka/pro/routing/features/direct_assignments/topic.rb".freeze, "lib/karafka/pro/routing/features/expiring.rb".freeze, "lib/karafka/pro/routing/features/expiring/config.rb".freeze, "lib/karafka/pro/routing/features/expiring/contracts/topic.rb".freeze, "lib/karafka/pro/routing/features/expiring/topic.rb".freeze, "lib/karafka/pro/routing/features/filtering.rb".freeze, "lib/karafka/pro/routing/features/filtering/config.rb".freeze, "lib/karafka/pro/routing/features/filtering/contracts/topic.rb".freeze, "lib/karafka/pro/routing/features/filtering/topic.rb".freeze, "lib/karafka/pro/routing/features/inline_insights.rb".freeze, "lib/karafka/pro/routing/features/inline_insights/config.rb".freeze, "lib/karafka/pro/routing/features/inline_insights/contracts/topic.rb".freeze, "lib/karafka/pro/routing/features/inline_insights/topic.rb".freeze, "lib/karafka/pro/routing/features/long_running_job.rb".freeze, "lib/karafka/pro/routing/features/long_running_job/config.rb".freeze, "lib/karafka/pro/routing/features/long_running_job/contracts/topic.rb".freeze, "lib/karafka/pro/routing/features/long_running_job/topic.rb".freeze, "lib/karafka/pro/routing/features/multiplexing.rb".freeze, "lib/karafka/pro/routing/features/multiplexing/config.rb".freeze, "lib/karafka/pro/routing/features/multiplexing/contracts/topic.rb".freeze, "lib/karafka/pro/routing/features/multiplexing/patches/contracts/consumer_group.rb".freeze, "lib/karafka/pro/routing/features/multiplexing/proxy.rb".freeze, "lib/karafka/pro/routing/features/multiplexing/subscription_group.rb".freeze, "lib/karafka/pro/routing/features/multiplexing/subscription_groups_builder.rb".freeze, "lib/karafka/pro/routing/features/non_blocking_job.rb".freeze, "lib/karafka/pro/routing/features/non_blocking_job/topic.rb".freeze, "lib/karafka/pro/routing/features/offset_metadata.rb".freeze, "lib/karafka/pro/routing/features/offset_metadata/config.rb".freeze, "lib/karafka/pro/routing/features/offset_metadata/contracts/topic.rb".freeze, "lib/karafka/pro/routing/features/offset_metadata/topic.rb".freeze, "lib/karafka/pro/routing/features/patterns.rb".freeze, "lib/karafka/pro/routing/features/patterns/builder.rb".freeze, "lib/karafka/pro/routing/features/patterns/config.rb".freeze, "lib/karafka/pro/routing/features/patterns/consumer_group.rb".freeze, "lib/karafka/pro/routing/features/patterns/contracts/consumer_group.rb".freeze, "lib/karafka/pro/routing/features/patterns/contracts/pattern.rb".freeze, "lib/karafka/pro/routing/features/patterns/contracts/topic.rb".freeze, "lib/karafka/pro/routing/features/patterns/detector.rb".freeze, "lib/karafka/pro/routing/features/patterns/pattern.rb".freeze, "lib/karafka/pro/routing/features/patterns/patterns.rb".freeze, "lib/karafka/pro/routing/features/patterns/topic.rb".freeze, "lib/karafka/pro/routing/features/patterns/topics.rb".freeze, "lib/karafka/pro/routing/features/pausing.rb".freeze, "lib/karafka/pro/routing/features/pausing/contracts/topic.rb".freeze, "lib/karafka/pro/routing/features/pausing/topic.rb".freeze, "lib/karafka/pro/routing/features/periodic_job.rb".freeze, "lib/karafka/pro/routing/features/periodic_job/config.rb".freeze, "lib/karafka/pro/routing/features/periodic_job/contracts/topic.rb".freeze, "lib/karafka/pro/routing/features/periodic_job/topic.rb".freeze, "lib/karafka/pro/routing/features/recurring_tasks.rb".freeze, "lib/karafka/pro/routing/features/recurring_tasks/builder.rb".freeze, "lib/karafka/pro/routing/features/recurring_tasks/config.rb".freeze, "lib/karafka/pro/routing/features/recurring_tasks/contracts/topic.rb".freeze, "lib/karafka/pro/routing/features/recurring_tasks/proxy.rb".freeze, "lib/karafka/pro/routing/features/recurring_tasks/topic.rb".freeze, "lib/karafka/pro/routing/features/scheduled_messages.rb".freeze, "lib/karafka/pro/routing/features/scheduled_messages/builder.rb".freeze, "lib/karafka/pro/routing/features/scheduled_messages/config.rb".freeze, "lib/karafka/pro/routing/features/scheduled_messages/contracts/topic.rb".freeze, "lib/karafka/pro/routing/features/scheduled_messages/proxy.rb".freeze, "lib/karafka/pro/routing/features/scheduled_messages/topic.rb".freeze, "lib/karafka/pro/routing/features/swarm.rb".freeze, "lib/karafka/pro/routing/features/swarm/config.rb".freeze, "lib/karafka/pro/routing/features/swarm/contracts/routing.rb".freeze, "lib/karafka/pro/routing/features/swarm/contracts/topic.rb".freeze, "lib/karafka/pro/routing/features/swarm/topic.rb".freeze, "lib/karafka/pro/routing/features/throttling.rb".freeze, "lib/karafka/pro/routing/features/throttling/config.rb".freeze, "lib/karafka/pro/routing/features/throttling/contracts/topic.rb".freeze, "lib/karafka/pro/routing/features/throttling/topic.rb".freeze, "lib/karafka/pro/routing/features/virtual_partitions.rb".freeze, "lib/karafka/pro/routing/features/virtual_partitions/config.rb".freeze, "lib/karafka/pro/routing/features/virtual_partitions/contracts/topic.rb".freeze, "lib/karafka/pro/routing/features/virtual_partitions/topic.rb".freeze, "lib/karafka/pro/scheduled_messages.rb".freeze, "lib/karafka/pro/scheduled_messages/consumer.rb".freeze, "lib/karafka/pro/scheduled_messages/contracts/config.rb".freeze, "lib/karafka/pro/scheduled_messages/contracts/message.rb".freeze, "lib/karafka/pro/scheduled_messages/daily_buffer.rb".freeze, "lib/karafka/pro/scheduled_messages/day.rb".freeze, "lib/karafka/pro/scheduled_messages/deserializers/headers.rb".freeze, "lib/karafka/pro/scheduled_messages/deserializers/payload.rb".freeze, "lib/karafka/pro/scheduled_messages/dispatcher.rb".freeze, "lib/karafka/pro/scheduled_messages/errors.rb".freeze, "lib/karafka/pro/scheduled_messages/max_epoch.rb".freeze, "lib/karafka/pro/scheduled_messages/proxy.rb".freeze, "lib/karafka/pro/scheduled_messages/schema_validator.rb".freeze, "lib/karafka/pro/scheduled_messages/serializer.rb".freeze, "lib/karafka/pro/scheduled_messages/setup/config.rb".freeze, "lib/karafka/pro/scheduled_messages/state.rb".freeze, "lib/karafka/pro/scheduled_messages/tracker.rb".freeze, "lib/karafka/pro/swarm/liveness_listener.rb".freeze, "lib/karafka/process.rb".freeze, "lib/karafka/processing/coordinator.rb".freeze, "lib/karafka/processing/coordinators_buffer.rb".freeze, "lib/karafka/processing/executor.rb".freeze, "lib/karafka/processing/executors_buffer.rb".freeze, "lib/karafka/processing/expansions_selector.rb".freeze, "lib/karafka/processing/inline_insights/consumer.rb".freeze, "lib/karafka/processing/inline_insights/listener.rb".freeze, "lib/karafka/processing/inline_insights/tracker.rb".freeze, "lib/karafka/processing/jobs/base.rb".freeze, "lib/karafka/processing/jobs/consume.rb".freeze, "lib/karafka/processing/jobs/eofed.rb".freeze, "lib/karafka/processing/jobs/idle.rb".freeze, "lib/karafka/processing/jobs/revoked.rb".freeze, "lib/karafka/processing/jobs/shutdown.rb".freeze, "lib/karafka/processing/jobs_builder.rb".freeze, "lib/karafka/processing/jobs_queue.rb".freeze, "lib/karafka/processing/partitioner.rb".freeze, "lib/karafka/processing/result.rb".freeze, "lib/karafka/processing/schedulers/default.rb".freeze, "lib/karafka/processing/strategies/aj_dlq_mom.rb".freeze, "lib/karafka/processing/strategies/aj_mom.rb".freeze, "lib/karafka/processing/strategies/base.rb".freeze, "lib/karafka/processing/strategies/default.rb".freeze, "lib/karafka/processing/strategies/dlq.rb".freeze, "lib/karafka/processing/strategies/dlq_mom.rb".freeze, "lib/karafka/processing/strategies/mom.rb".freeze, "lib/karafka/processing/strategy_selector.rb".freeze, "lib/karafka/processing/timed_queue.rb".freeze, "lib/karafka/processing/worker.rb".freeze, "lib/karafka/processing/workers_batch.rb".freeze, "lib/karafka/railtie.rb".freeze, "lib/karafka/routing/activity_manager.rb".freeze, "lib/karafka/routing/builder.rb".freeze, "lib/karafka/routing/consumer_group.rb".freeze, "lib/karafka/routing/features/active_job.rb".freeze, "lib/karafka/routing/features/active_job/builder.rb".freeze, "lib/karafka/routing/features/active_job/config.rb".freeze, "lib/karafka/routing/features/active_job/contracts/topic.rb".freeze, "lib/karafka/routing/features/active_job/proxy.rb".freeze, "lib/karafka/routing/features/active_job/topic.rb".freeze, "lib/karafka/routing/features/base.rb".freeze, "lib/karafka/routing/features/base/expander.rb".freeze, "lib/karafka/routing/features/dead_letter_queue.rb".freeze, "lib/karafka/routing/features/dead_letter_queue/config.rb".freeze, "lib/karafka/routing/features/dead_letter_queue/contracts/topic.rb".freeze, "lib/karafka/routing/features/dead_letter_queue/topic.rb".freeze, "lib/karafka/routing/features/declaratives.rb".freeze, "lib/karafka/routing/features/declaratives/config.rb".freeze, "lib/karafka/routing/features/declaratives/contracts/topic.rb".freeze, "lib/karafka/routing/features/declaratives/topic.rb".freeze, "lib/karafka/routing/features/deserializers.rb".freeze, "lib/karafka/routing/features/deserializers/config.rb".freeze, "lib/karafka/routing/features/deserializers/contracts/topic.rb".freeze, "lib/karafka/routing/features/deserializers/topic.rb".freeze, "lib/karafka/routing/features/eofed.rb".freeze, "lib/karafka/routing/features/eofed/config.rb".freeze, "lib/karafka/routing/features/eofed/contracts/topic.rb".freeze, "lib/karafka/routing/features/eofed/topic.rb".freeze, "lib/karafka/routing/features/inline_insights.rb".freeze, "lib/karafka/routing/features/inline_insights/config.rb".freeze, "lib/karafka/routing/features/inline_insights/contracts/topic.rb".freeze, "lib/karafka/routing/features/inline_insights/topic.rb".freeze, "lib/karafka/routing/features/manual_offset_management.rb".freeze, "lib/karafka/routing/features/manual_offset_management/config.rb".freeze, "lib/karafka/routing/features/manual_offset_management/contracts/topic.rb".freeze, "lib/karafka/routing/features/manual_offset_management/topic.rb".freeze, "lib/karafka/routing/proxy.rb".freeze, "lib/karafka/routing/router.rb".freeze, "lib/karafka/routing/subscription_group.rb".freeze, "lib/karafka/routing/subscription_groups_builder.rb".freeze, "lib/karafka/routing/topic.rb".freeze, "lib/karafka/routing/topics.rb".freeze, "lib/karafka/runner.rb".freeze, "lib/karafka/server.rb".freeze, "lib/karafka/setup/attributes_map.rb".freeze, "lib/karafka/setup/config.rb".freeze, "lib/karafka/setup/defaults_injector.rb".freeze, "lib/karafka/setup/dsl.rb".freeze, "lib/karafka/status.rb".freeze, "lib/karafka/swarm.rb".freeze, "lib/karafka/swarm/liveness_listener.rb".freeze, "lib/karafka/swarm/manager.rb".freeze, "lib/karafka/swarm/node.rb".freeze, "lib/karafka/swarm/pidfd.rb".freeze, "lib/karafka/swarm/supervisor.rb".freeze, "lib/karafka/templates/application_consumer.rb.erb".freeze, "lib/karafka/templates/example_consumer.rb.erb".freeze, "lib/karafka/templates/karafka.rb.erb".freeze, "lib/karafka/time_trackers/base.rb".freeze, "lib/karafka/time_trackers/pause.rb".freeze, "lib/karafka/time_trackers/poll.rb".freeze, "lib/karafka/version.rb".freeze, "log/.gitkeep".freeze, "renovate.json".freeze]
  s.homepage = "https://karafka.io".freeze
  s.licenses = ["LGPL-3.0-only".freeze, "Commercial".freeze]
  s.required_ruby_version = Gem::Requirement.new(">= 3.0.0".freeze)
  s.rubygems_version = "3.5.10".freeze
  s.summary = "Karafka is Ruby and Rails efficient Kafka processing framework.".freeze

  s.specification_version = 4

  s.add_runtime_dependency(%q<base64>.freeze, ["~> 0.2".freeze])
  s.add_runtime_dependency(%q<karafka-core>.freeze, [">= 2.4.3".freeze, "< 2.5.0".freeze])
  s.add_runtime_dependency(%q<karafka-rdkafka>.freeze, [">= 0.17.2".freeze])
  s.add_runtime_dependency(%q<waterdrop>.freeze, [">= 2.7.3".freeze, "< 3.0.0".freeze])
  s.add_runtime_dependency(%q<zeitwerk>.freeze, ["~> 2.3".freeze])
end