--- !ruby/object:Gem::Specification name: karafka version: !ruby/object:Gem::Version version: 2.0.39 platform: ruby authors: - Maciej Mensfeld autorequire: bindir: bin cert_chain: - | -----BEGIN CERTIFICATE----- MIIEcDCCAtigAwIBAgIBATANBgkqhkiG9w0BAQsFADA/MRAwDgYDVQQDDAdjb250 YWN0MRcwFQYKCZImiZPyLGQBGRYHa2FyYWZrYTESMBAGCgmSJomT8ixkARkWAmlv MB4XDTIyMDgxOTE3MjEzN1oXDTIzMDgxOTE3MjEzN1owPzEQMA4GA1UEAwwHY29u dGFjdDEXMBUGCgmSJomT8ixkARkWB2thcmFma2ExEjAQBgoJkiaJk/IsZAEZFgJp bzCCAaIwDQYJKoZIhvcNAQEBBQADggGPADCCAYoCggGBAODzeO3L6lxdATzMHKNW jFA/GGunoPuylO/BMzy8RiQHh7VIvysAKs0tHhTx3g2D0STDpF+hcQcPELFikiT2 F+1wOHj/SsrK7VKqfA8+gq04hKc5sQoX2Egf9k3V0YJ3eZ6R/koHkQ8A0TVt0w6F ZQckoV4MqnEAx0g/FZN3mnHTlJ3VFLSBqJEIe+S6FZMl92mSv+hTrlUG8VaYxSfN lTCvnKk284F6QZq5XIENLRmcDd/3aPBLnLwNnyMyhB+6gK8cUO+CFlDO5tjo/aBA rUnl++wGG0JooF1ed0v+evOn9KoMBG6rHewcf79qJbVOscbD8qSAmo+sCXtcFryr KRMTB8gNbowJkFRJDEe8tfRy11u1fYzFg/qNO82FJd62rKAw2wN0C29yCeQOPRb1 Cw9Y4ZwK9VFNEcV9L+3pHTHn2XfuZHtDaG198VweiF6raFO4yiEYccodH/USP0L5 cbcCFtmu/4HDSxL1ByQXO84A0ybJuk3/+aPUSXe9C9U8fwIDAQABo3cwdTAJBgNV HRMEAjAAMAsGA1UdDwQEAwIEsDAdBgNVHQ4EFgQUSlcEakb7gfn/5E2WY6z73BF/ iZkwHQYDVR0RBBYwFIESY29udGFjdEBrYXJhZmthLmlvMB0GA1UdEgQWMBSBEmNv bnRhY3RAa2FyYWZrYS5pbzANBgkqhkiG9w0BAQsFAAOCAYEA1aS+E7RXJ1w9g9mJ G0NzFxe64OEuENosNlvYQCbRKGCXAU1qqelYkBQHseRgRKxLICrnypRo9IEobyHa vDnJ4r7Tsb34dleqQW2zY/obG+cia3Ym2JsegXWF7dDOzCXJ4FN8MFoT2jHlqLLw yrap0YO5zx0GSQ0Dwy8h2n2v2vanMEeCx7iNm3ERgR5WuN5sjzWoz2A/JLEEcK0C EnAGKCWAd1fuG8IemDjT1edsd5FyYR4bIX0m+99oDuFZyPiiIbalmyYiSBBp59Yb Q0P8zeBi4OfwCZNcxqz0KONmw9JLNv6DgyEAH5xe/4JzhMEgvIRiPj0pHfA7oqQF KUNqvD1KlxbEC+bZfE5IZhnqYLdld/Ksqd22FI1RBhiS1Ejfsj99LVIm9cBuZEY2 Qf04B9ceLUaC4fPVEz10FyobjaFoY4i32xRto3XnrzeAgfEe4swLq8bQsR3w/EF3 MGU0FeSV2Yj7Xc2x/7BzLK8xQn5l7Yy75iPF+KP3vVmDHnNl -----END CERTIFICATE----- date: 2023-04-11 00:00:00.000000000 Z dependencies: - !ruby/object:Gem::Dependency name: karafka-core requirement: !ruby/object:Gem::Requirement requirements: - - ">=" - !ruby/object:Gem::Version version: 2.0.12 - - "<" - !ruby/object:Gem::Version version: 3.0.0 type: :runtime prerelease: false version_requirements: !ruby/object:Gem::Requirement requirements: - - ">=" - !ruby/object:Gem::Version version: 2.0.12 - - "<" - !ruby/object:Gem::Version version: 3.0.0 - !ruby/object:Gem::Dependency name: thor requirement: !ruby/object:Gem::Requirement requirements: - - ">=" - !ruby/object:Gem::Version version: '0.20' type: :runtime prerelease: false version_requirements: !ruby/object:Gem::Requirement requirements: - - ">=" - !ruby/object:Gem::Version version: '0.20' - !ruby/object:Gem::Dependency name: waterdrop requirement: !ruby/object:Gem::Requirement requirements: - - ">=" - !ruby/object:Gem::Version version: 2.4.10 - - "<" - !ruby/object:Gem::Version version: 3.0.0 type: :runtime prerelease: false version_requirements: !ruby/object:Gem::Requirement requirements: - - ">=" - !ruby/object:Gem::Version version: 2.4.10 - - "<" - !ruby/object:Gem::Version version: 3.0.0 - !ruby/object:Gem::Dependency name: zeitwerk requirement: !ruby/object:Gem::Requirement requirements: - - "~>" - !ruby/object:Gem::Version version: '2.3' type: :runtime prerelease: false version_requirements: !ruby/object:Gem::Requirement requirements: - - "~>" - !ruby/object:Gem::Version version: '2.3' description: |2 Karafka is Ruby and Rails efficient Kafka processing framework. Karafka allows you to capture everything that happens in your systems in large scale, without having to focus on things that are not your business domain. email: - contact@karafka.io executables: - karafka extensions: [] extra_rdoc_files: [] files: - ".coditsu/ci.yml" - ".console_irbrc" - ".diffend.yml" - ".github/FUNDING.yml" - ".github/ISSUE_TEMPLATE/bug_report.md" - ".github/ISSUE_TEMPLATE/feature_request.md" - ".github/workflows/ci.yml" - ".gitignore" - ".rspec" - ".ruby-gemset" - ".ruby-version" - CHANGELOG.md - CODE_OF_CONDUCT.md - CONTRIBUTING.md - Gemfile - Gemfile.lock - LICENSE - LICENSE-COMM - LICENSE-LGPL - README.md - bin/benchmarks - bin/create_token - bin/integrations - bin/karafka - bin/rspecs - bin/scenario - bin/stress_many - bin/stress_one - bin/verify_license_integrity - certs/cert_chain.pem - certs/karafka-pro.pem - config/locales/errors.yml - config/locales/pro_errors.yml - docker-compose.yml - karafka.gemspec - lib/active_job/karafka.rb - lib/active_job/queue_adapters/karafka_adapter.rb - lib/karafka.rb - lib/karafka/active_job/consumer.rb - lib/karafka/active_job/dispatcher.rb - lib/karafka/active_job/job_extensions.rb - lib/karafka/active_job/job_options_contract.rb - lib/karafka/admin.rb - lib/karafka/app.rb - lib/karafka/base_consumer.rb - lib/karafka/cli.rb - lib/karafka/cli/base.rb - lib/karafka/cli/console.rb - lib/karafka/cli/info.rb - lib/karafka/cli/install.rb - lib/karafka/cli/server.rb - lib/karafka/cli/topics.rb - lib/karafka/connection/client.rb - lib/karafka/connection/consumer_group_coordinator.rb - lib/karafka/connection/listener.rb - lib/karafka/connection/listeners_batch.rb - lib/karafka/connection/messages_buffer.rb - lib/karafka/connection/pauses_manager.rb - lib/karafka/connection/raw_messages_buffer.rb - lib/karafka/connection/rebalance_manager.rb - lib/karafka/contracts.rb - lib/karafka/contracts/base.rb - lib/karafka/contracts/config.rb - lib/karafka/contracts/consumer_group.rb - lib/karafka/contracts/server_cli_options.rb - lib/karafka/contracts/topic.rb - lib/karafka/embedded.rb - lib/karafka/env.rb - lib/karafka/errors.rb - lib/karafka/helpers/async.rb - lib/karafka/helpers/colorize.rb - lib/karafka/helpers/multi_delegator.rb - lib/karafka/instrumentation/callbacks/error.rb - lib/karafka/instrumentation/callbacks/statistics.rb - lib/karafka/instrumentation/logger.rb - lib/karafka/instrumentation/logger_listener.rb - lib/karafka/instrumentation/monitor.rb - lib/karafka/instrumentation/notifications.rb - lib/karafka/instrumentation/proctitle_listener.rb - lib/karafka/instrumentation/vendors/datadog/dashboard.json - lib/karafka/instrumentation/vendors/datadog/listener.rb - lib/karafka/instrumentation/vendors/datadog/logger_listener.rb - lib/karafka/instrumentation/vendors/datadog/metrics_listener.rb - lib/karafka/licenser.rb - lib/karafka/messages/batch_metadata.rb - lib/karafka/messages/builders/batch_metadata.rb - lib/karafka/messages/builders/message.rb - lib/karafka/messages/builders/messages.rb - lib/karafka/messages/message.rb - lib/karafka/messages/messages.rb - lib/karafka/messages/metadata.rb - lib/karafka/messages/parser.rb - lib/karafka/messages/seek.rb - lib/karafka/patches/rdkafka/bindings.rb - lib/karafka/patches/rdkafka/consumer.rb - lib/karafka/pro.rb - lib/karafka/pro/active_job/consumer.rb - lib/karafka/pro/active_job/dispatcher.rb - lib/karafka/pro/active_job/job_options_contract.rb - lib/karafka/pro/base_consumer.rb - lib/karafka/pro/encryption.rb - lib/karafka/pro/encryption/cipher.rb - lib/karafka/pro/encryption/contracts/config.rb - lib/karafka/pro/encryption/errors.rb - lib/karafka/pro/encryption/messages/middleware.rb - lib/karafka/pro/encryption/messages/parser.rb - lib/karafka/pro/encryption/setup/config.rb - lib/karafka/pro/loader.rb - lib/karafka/pro/performance_tracker.rb - lib/karafka/pro/processing/collapser.rb - lib/karafka/pro/processing/coordinator.rb - lib/karafka/pro/processing/filters/base.rb - lib/karafka/pro/processing/filters/delayer.rb - lib/karafka/pro/processing/filters/expirer.rb - lib/karafka/pro/processing/filters/throttler.rb - lib/karafka/pro/processing/filters_applier.rb - lib/karafka/pro/processing/jobs/consume_non_blocking.rb - lib/karafka/pro/processing/jobs/revoked_non_blocking.rb - lib/karafka/pro/processing/jobs_builder.rb - lib/karafka/pro/processing/partitioner.rb - lib/karafka/pro/processing/scheduler.rb - lib/karafka/pro/processing/strategies.rb - lib/karafka/pro/processing/strategies/aj/dlq_ftr_lrj_mom.rb - lib/karafka/pro/processing/strategies/aj/dlq_ftr_lrj_mom_vp.rb - lib/karafka/pro/processing/strategies/aj/dlq_ftr_mom.rb - lib/karafka/pro/processing/strategies/aj/dlq_ftr_mom_vp.rb - lib/karafka/pro/processing/strategies/aj/dlq_lrj_mom.rb - lib/karafka/pro/processing/strategies/aj/dlq_lrj_mom_vp.rb - lib/karafka/pro/processing/strategies/aj/dlq_mom.rb - lib/karafka/pro/processing/strategies/aj/dlq_mom_vp.rb - lib/karafka/pro/processing/strategies/aj/ftr_lrj_mom.rb - lib/karafka/pro/processing/strategies/aj/ftr_lrj_mom_vp.rb - lib/karafka/pro/processing/strategies/aj/ftr_mom.rb - lib/karafka/pro/processing/strategies/aj/ftr_mom_vp.rb - lib/karafka/pro/processing/strategies/aj/lrj_mom.rb - lib/karafka/pro/processing/strategies/aj/lrj_mom_vp.rb - lib/karafka/pro/processing/strategies/aj/mom.rb - lib/karafka/pro/processing/strategies/aj/mom_vp.rb - lib/karafka/pro/processing/strategies/base.rb - lib/karafka/pro/processing/strategies/default.rb - lib/karafka/pro/processing/strategies/dlq/default.rb - lib/karafka/pro/processing/strategies/dlq/ftr.rb - lib/karafka/pro/processing/strategies/dlq/ftr_lrj.rb - lib/karafka/pro/processing/strategies/dlq/ftr_lrj_mom.rb - lib/karafka/pro/processing/strategies/dlq/ftr_lrj_vp.rb - lib/karafka/pro/processing/strategies/dlq/ftr_mom.rb - lib/karafka/pro/processing/strategies/dlq/ftr_vp.rb - lib/karafka/pro/processing/strategies/dlq/lrj.rb - lib/karafka/pro/processing/strategies/dlq/lrj_mom.rb - lib/karafka/pro/processing/strategies/dlq/lrj_vp.rb - lib/karafka/pro/processing/strategies/dlq/mom.rb - lib/karafka/pro/processing/strategies/dlq/vp.rb - lib/karafka/pro/processing/strategies/ftr/default.rb - lib/karafka/pro/processing/strategies/ftr/vp.rb - lib/karafka/pro/processing/strategies/lrj/default.rb - lib/karafka/pro/processing/strategies/lrj/ftr.rb - lib/karafka/pro/processing/strategies/lrj/ftr_mom.rb - lib/karafka/pro/processing/strategies/lrj/ftr_vp.rb - lib/karafka/pro/processing/strategies/lrj/mom.rb - lib/karafka/pro/processing/strategies/lrj/vp.rb - lib/karafka/pro/processing/strategies/mom/default.rb - lib/karafka/pro/processing/strategies/mom/ftr.rb - lib/karafka/pro/processing/strategies/vp/default.rb - lib/karafka/pro/processing/strategy_selector.rb - lib/karafka/pro/routing/features/base.rb - lib/karafka/pro/routing/features/dead_letter_queue.rb - lib/karafka/pro/routing/features/dead_letter_queue/contract.rb - lib/karafka/pro/routing/features/delaying.rb - lib/karafka/pro/routing/features/delaying/config.rb - lib/karafka/pro/routing/features/delaying/contract.rb - lib/karafka/pro/routing/features/delaying/topic.rb - lib/karafka/pro/routing/features/expiring.rb - lib/karafka/pro/routing/features/expiring/config.rb - lib/karafka/pro/routing/features/expiring/contract.rb - lib/karafka/pro/routing/features/expiring/topic.rb - lib/karafka/pro/routing/features/filtering.rb - lib/karafka/pro/routing/features/filtering/config.rb - lib/karafka/pro/routing/features/filtering/contract.rb - lib/karafka/pro/routing/features/filtering/topic.rb - lib/karafka/pro/routing/features/long_running_job.rb - lib/karafka/pro/routing/features/long_running_job/config.rb - lib/karafka/pro/routing/features/long_running_job/contract.rb - lib/karafka/pro/routing/features/long_running_job/topic.rb - lib/karafka/pro/routing/features/throttling.rb - lib/karafka/pro/routing/features/throttling/config.rb - lib/karafka/pro/routing/features/throttling/contract.rb - lib/karafka/pro/routing/features/throttling/topic.rb - lib/karafka/pro/routing/features/virtual_partitions.rb - lib/karafka/pro/routing/features/virtual_partitions/config.rb - lib/karafka/pro/routing/features/virtual_partitions/contract.rb - lib/karafka/pro/routing/features/virtual_partitions/topic.rb - lib/karafka/process.rb - lib/karafka/processing/coordinator.rb - lib/karafka/processing/coordinators_buffer.rb - lib/karafka/processing/executor.rb - lib/karafka/processing/executors_buffer.rb - lib/karafka/processing/jobs/base.rb - lib/karafka/processing/jobs/consume.rb - lib/karafka/processing/jobs/idle.rb - lib/karafka/processing/jobs/revoked.rb - lib/karafka/processing/jobs/shutdown.rb - lib/karafka/processing/jobs_builder.rb - lib/karafka/processing/jobs_queue.rb - lib/karafka/processing/partitioner.rb - lib/karafka/processing/result.rb - lib/karafka/processing/scheduler.rb - lib/karafka/processing/strategies/aj_dlq_mom.rb - lib/karafka/processing/strategies/aj_mom.rb - lib/karafka/processing/strategies/base.rb - lib/karafka/processing/strategies/default.rb - lib/karafka/processing/strategies/dlq.rb - lib/karafka/processing/strategies/dlq_mom.rb - lib/karafka/processing/strategies/mom.rb - lib/karafka/processing/strategy_selector.rb - lib/karafka/processing/worker.rb - lib/karafka/processing/workers_batch.rb - lib/karafka/railtie.rb - lib/karafka/routing/activity_manager.rb - lib/karafka/routing/builder.rb - lib/karafka/routing/consumer_group.rb - lib/karafka/routing/consumer_mapper.rb - lib/karafka/routing/features/active_job.rb - lib/karafka/routing/features/active_job/builder.rb - lib/karafka/routing/features/active_job/config.rb - lib/karafka/routing/features/active_job/contract.rb - lib/karafka/routing/features/active_job/topic.rb - lib/karafka/routing/features/base.rb - lib/karafka/routing/features/base/expander.rb - lib/karafka/routing/features/dead_letter_queue.rb - lib/karafka/routing/features/dead_letter_queue/config.rb - lib/karafka/routing/features/dead_letter_queue/contract.rb - lib/karafka/routing/features/dead_letter_queue/topic.rb - lib/karafka/routing/features/declaratives.rb - lib/karafka/routing/features/declaratives/config.rb - lib/karafka/routing/features/declaratives/contract.rb - lib/karafka/routing/features/declaratives/topic.rb - lib/karafka/routing/features/manual_offset_management.rb - lib/karafka/routing/features/manual_offset_management/config.rb - lib/karafka/routing/features/manual_offset_management/contract.rb - lib/karafka/routing/features/manual_offset_management/topic.rb - lib/karafka/routing/proxy.rb - lib/karafka/routing/router.rb - lib/karafka/routing/subscription_group.rb - lib/karafka/routing/subscription_groups_builder.rb - lib/karafka/routing/topic.rb - lib/karafka/routing/topics.rb - lib/karafka/runner.rb - lib/karafka/serialization/json/deserializer.rb - lib/karafka/server.rb - lib/karafka/setup/attributes_map.rb - lib/karafka/setup/config.rb - lib/karafka/setup/dsl.rb - lib/karafka/status.rb - lib/karafka/templates/application_consumer.rb.erb - lib/karafka/templates/example_consumer.rb.erb - lib/karafka/templates/karafka.rb.erb - lib/karafka/time_trackers/base.rb - lib/karafka/time_trackers/pause.rb - lib/karafka/time_trackers/poll.rb - lib/karafka/version.rb - log/.gitkeep - renovate.json homepage: https://karafka.io licenses: - LGPL-3.0 - Commercial metadata: funding_uri: https://karafka.io/#become-pro homepage_uri: https://karafka.io changelog_uri: https://github.com/karafka/karafka/blob/master/CHANGELOG.md bug_tracker_uri: https://github.com/karafka/karafka/issues source_code_uri: https://github.com/karafka/karafka documentation_uri: https://karafka.io/docs rubygems_mfa_required: 'true' post_install_message: rdoc_options: [] require_paths: - lib required_ruby_version: !ruby/object:Gem::Requirement requirements: - - ">=" - !ruby/object:Gem::Version version: '0' required_rubygems_version: !ruby/object:Gem::Requirement requirements: - - ">=" - !ruby/object:Gem::Version version: '0' requirements: [] rubygems_version: 3.4.10 signing_key: specification_version: 4 summary: Karafka is Ruby and Rails efficient Kafka processing framework. test_files: []