Method List

Classes Methods Files

Search:

#<< Karafka::Processing::JobsQueue
#<< Karafka::Connection::RawMessagesBuffer
activate Karafka::Routing::Features::Base
#active Karafka::Pro::Routing::Features::LongRunningJob::Config
#active Karafka::Routing::Features::ActiveJob::Config
#active Karafka::Routing::Features::DeadLetterQueue::Config
#active Karafka::Routing::Builder
#active Karafka::Routing::Topic
#active Karafka::Routing::Features::ManualOffsetManagement::Config
#active Karafka::Pro::Routing::Features::VirtualPartitions::Config
#active? Karafka::Routing::Topic
#active? Karafka::Routing::SubscriptionGroup
#active? Karafka::Routing::ConsumerGroup
#active_job Karafka::Routing::Features::ActiveJob::Topic
#active_job? Karafka::Routing::Features::ActiveJob::Topic
#active_job_topic Karafka::Routing::Features::ActiveJob::Builder
#after_call Karafka::Processing::Jobs::Consume
#after_call Karafka::Processing::Jobs::Base
#after_consume Karafka::Processing::Executor
#assigned_partitions Karafka::Connection::RebalanceManager
#async_call Karafka::Helpers::Async
#attempt Karafka::TimeTrackers::Pause
#attempts Karafka::TimeTrackers::Poll
#backoff Karafka::TimeTrackers::Poll
#batch_poll Karafka::Connection::Client
#before_call Karafka::Processing::Jobs::Consume
#before_call Karafka::Processing::Jobs::Base
#before_consume Karafka::Processing::Executor
#before_enqueue Karafka::Processing::Jobs::Consume
#before_enqueue Karafka::Processing::Jobs::Base
#before_enqueue Karafka::Processing::Executor
bind_to Karafka::Cli::Base
boot_file Karafka
#call Karafka::Runner
#call Karafka::Messages::Parser
#call Karafka::Pro::ActiveJob::Dispatcher
#call Karafka::Connection::Listener
#call Karafka::Cli::Base
#call Karafka::Processing::Jobs::Shutdown
call Karafka::Messages::Builders::Message
#call Karafka::Instrumentation::Callbacks::Statistics
#call Karafka::Routing::SubscriptionGroupsBuilder
#call Karafka::Processing::Jobs::Consume
#call Karafka::Processing::Jobs::Revoked
call Karafka::Messages::Builders::Messages
#call Karafka::Serialization::Json::Deserializer
#call Karafka::ActiveJob::Dispatcher
#call Karafka::Processing::Jobs::Base
#call Karafka::Pro::Encryption::Messages::Parser
call Karafka::Messages::Builders::BatchMetadata
#call Karafka::Routing::ConsumerMapper
#call Karafka::Cli::Server
#call Karafka::Cli::Console
#call Karafka::Instrumentation::Callbacks::Error
#call Karafka::Pro::Encryption::Messages::Middleware
#call Karafka::Cli::Info
#call Karafka::Processing::Partitioner
#call Karafka::Pro::Processing::Partitioner
#call Karafka::Cli::Install
#cause Karafka::Processing::Result
#changed? Karafka::Connection::RebalanceManager
#checkpoint Karafka::TimeTrackers::Poll
#clear Karafka::Connection::RawMessagesBuffer
#clear Karafka::Processing::JobsQueue
#clear Karafka::Routing::Builder
#clear Karafka::Connection::RebalanceManager
#clear Karafka::Processing::ExecutorsBuffer
#cli Karafka::Cli::Base
#client Karafka::BaseConsumer
#close Karafka::Processing::JobsQueue
cluster_info Karafka::Admin
command Karafka::Cli::Console
#commit_offsets Karafka::Connection::Client
#commit_offsets! Karafka::Connection::Client
#complete Karafka::Processing::JobsQueue
#config Karafka::Setup::Dsl
#consume Karafka::Processing::Executor
#consume Karafka::Processing::JobsBuilder
#consume Karafka::Pro::Processing::JobsBuilder
#consume Karafka::ActiveJob::Consumer
#consume Karafka::Pro::ActiveJob::Consumer
consumer Karafka::Setup::AttributesMap
#consumer Karafka::Routing::Topic
#consumer_class Karafka::Routing::Topic
#consumer_group Karafka::Routing::SubscriptionGroup
#consumer_group Karafka::Routing::Topic
#consumer_group_id Karafka::Routing::SubscriptionGroup
consumer_groups Karafka::App
#consumption Karafka::Processing::Coordinator
#consumption_lag Karafka::Messages::BatchMetadata
#coordinator Karafka::BaseConsumer
#coordinators Karafka::Connection::ListenersBatch
core_root Karafka
create_topic Karafka::Admin
#created_at Karafka::Messages::BatchMetadata
#current_subscription_group_id Karafka::Routing::ConsumerGroup
#current_timeout Karafka::TimeTrackers::Pause
#dead_letter_queue Karafka::Routing::Features::DeadLetterQueue::Topic
#dead_letter_queue? Karafka::Routing::Features::DeadLetterQueue::Topic
#decrement Karafka::Processing::Coordinator
#decrypt Karafka::Pro::Encryption::Cipher
delegate Karafka::Helpers::MultiDelegator
#delete Karafka::Connection::RawMessagesBuffer
#delete_if Karafka::Routing::Topics
delete_topic Karafka::Admin
desc Karafka::Cli::Base
#deserialize! Karafka::Messages::Messages
#deserialized? Karafka::Messages::Message
#deserializer Karafka::Messages::Metadata
#deserializer Karafka::Messages::BatchMetadata
detect Karafka::Licenser
#dispatch_to_dlq Karafka::Processing::Strategies::Dlq
#dispatch_to_dlq Karafka::Pro::Processing::Strategies::Dlq
#dispatch_to_dlq? Karafka::Pro::Processing::Strategies::Dlq
#draw Karafka::Routing::Builder
#each Karafka::Routing::Topics
#each Karafka::Connection::MessagesBuffer
#each Karafka::Processing::ExecutorsBuffer
#each Karafka::Connection::ListenersBatch
#each Karafka::Messages::Messages
#each Karafka::Connection::RawMessagesBuffer
#each Karafka::Processing::WorkersBatch
#empty? Karafka::Connection::MessagesBuffer
#empty? Karafka::Processing::JobsQueue
#encrypt Karafka::Pro::Encryption::Cipher
#enqueue ActiveJob::QueueAdapters::KarafkaAdapter
#enqueue_at ActiveJob::QueueAdapters::KarafkaAdapter
env Karafka
env= Karafka
#exceeded? Karafka::TimeTrackers::Poll
#executor Karafka::Processing::Jobs::Base
#expire Karafka::TimeTrackers::Pause
#expired? Karafka::TimeTrackers::Pause
extended Karafka::ActiveJob::JobExtensions
#failure! Karafka::Processing::Result
#fetch Karafka::Connection::PausesManager
#find Karafka::Routing::Topics
find Karafka::Routing::Router
#find Karafka::Pro::Processing::StrategySelector
#find Karafka::Processing::StrategySelector
#find_all Karafka::Processing::ExecutorsBuffer
find_by Karafka::Routing::Router
#find_or_create Karafka::Processing::ExecutorsBuffer
#find_or_create Karafka::Processing::CoordinatorsBuffer
#find_skippable_message Karafka::Pro::Processing::Strategies::Dlq
#find_skippable_message Karafka::Processing::Strategies::Dlq
#finish_work Karafka::Connection::ConsumerGroupCoordinator
#finished? Karafka::Pro::Processing::Coordinator
#finished? Karafka::Connection::ConsumerGroupCoordinator
#first Karafka::Messages::Messages
#first_offset Karafka::Messages::BatchMetadata
gem_root Karafka
generate Karafka::Setup::AttributesMap
#green Karafka::Helpers::Colorize
#group_id Karafka::Processing::Executor
#handle_after_consume Karafka::Pro::Processing::Strategies::Default
#handle_after_consume Karafka::Pro::Processing::Strategies::DlqLrjMom
#handle_after_consume Karafka::Pro::Processing::Strategies::Mom
#handle_after_consume Karafka::Processing::Strategies::AjDlqMom
#handle_after_consume Karafka::Processing::Strategies::DlqMom
#handle_after_consume Karafka::Pro::Processing::Strategies::LrjMom
#handle_after_consume Karafka::Pro::Processing::Strategies::AjMomVp
#handle_after_consume Karafka::Pro::Processing::Strategies::Dlq
#handle_after_consume Karafka::Pro::Processing::Strategies::AjDlqMom
#handle_after_consume Karafka::Pro::Processing::Strategies::DlqMom
#handle_after_consume Karafka::Pro::Processing::Strategies::AjLrjMomVp
#handle_after_consume Karafka::Pro::Processing::Strategies::Lrj
#handle_after_consume Karafka::Processing::Strategies::Base
#handle_after_consume Karafka::Processing::Strategies::Dlq
#handle_after_consume Karafka::Processing::Strategies::Mom
#handle_after_consume Karafka::Pro::Processing::Strategies::DlqLrj
#handle_after_consume Karafka::Processing::Strategies::Default
#handle_before_consume Karafka::Processing::Strategies::Base
#handle_before_consume Karafka::Pro::Processing::Strategies::Default
#handle_before_consume Karafka::Processing::Strategies::Default
#handle_before_enqueue Karafka::Pro::Processing::Strategies::Default
#handle_before_enqueue Karafka::Pro::Processing::Strategies::Lrj
#handle_before_enqueue Karafka::Pro::Processing::Strategies::LrjMom
#handle_before_enqueue Karafka::Pro::Processing::Strategies::AjLrjMomVp
#handle_before_enqueue Karafka::Processing::Strategies::Default
#handle_before_enqueue Karafka::Processing::Strategies::Base
#handle_consume Karafka::Processing::Strategies::Default
#handle_consume Karafka::Pro::Processing::Strategies::Default
#handle_consume Karafka::Processing::Strategies::Base
#handle_revoked Karafka::Pro::Processing::Strategies::AjLrjMomVp
#handle_revoked Karafka::Processing::Strategies::Default
#handle_revoked Karafka::Pro::Processing::Strategies::Lrj
#handle_revoked Karafka::Pro::Processing::Strategies::LrjMom
#handle_revoked Karafka::Pro::Processing::Strategies::Default
#handle_revoked Karafka::Processing::Strategies::Base
#handle_shutdown Karafka::Processing::Strategies::Base
#handle_shutdown Karafka::Processing::Strategies::Default
#headers Karafka::Messages::Metadata
#id Karafka::Processing::Executor
#id Karafka::Connection::Listener
#id Karafka::Processing::Worker
#id Karafka::Connection::Client
#id Karafka::Routing::ConsumerGroup
#id Karafka::Routing::Topic
id Karafka::Routing::SubscriptionGroup
#id Karafka::BaseConsumer
#id Karafka::Routing::SubscriptionGroup
included Karafka::Helpers::Async
#increment Karafka::Processing::Coordinator
#increment Karafka::TimeTrackers::Pause
#initialize Karafka::Processing::Executor
#initialize Karafka::Instrumentation::Callbacks::Statistics
#initialize Karafka::Processing::StrategySelector
#initialize Karafka::Connection::Listener
#initialize Karafka::Instrumentation::Vendors::Datadog::Listener
#initialize Karafka::TimeTrackers::Poll
#initialize Karafka::Processing::Worker
#initialize Karafka::Processing::Result
#initialize Karafka::Messages::Messages
#initialize Karafka::Connection::MessagesBuffer
#initialize Karafka::Connection::Client
#initialize Karafka::Messages::Message
#initialize Karafka::Pro::Processing::Coordinator
#initialize Karafka::Processing::WorkersBatch
#initialize Karafka::Processing::Jobs::Consume
#initialize Karafka::Processing::Jobs::Revoked
#initialize Karafka::Routing::Topics
#initialize Karafka::Routing::Builder
#initialize Karafka::Routing::SubscriptionGroup
#initialize Karafka::Routing::Topic
#initialize Karafka::Routing::Proxy
#initialize Karafka::Pro::Processing::Jobs::ConsumeNonBlocking
#initialize Karafka::Connection::ListenersBatch
#initialize Karafka::Processing::Jobs::Shutdown
#initialize Karafka::BaseConsumer
#initialize Karafka::Connection::RebalanceManager
#initialize Karafka::Cli::Install
#initialize Karafka::Cli::Base
#initialize Karafka::Connection::RawMessagesBuffer
#initialize Karafka::Process
#initialize Karafka::Status
#initialize Karafka::Connection::PausesManager
#initialize Karafka::Instrumentation::Callbacks::Error
#initialize Karafka::Env
#initialize Karafka::Routing::Features::Base::Expander
#initialize Karafka::Helpers::MultiDelegator
#initialize Karafka::Routing::ConsumerGroup
#initialize Karafka::Processing::Partitioner
#initialize Karafka::Pro::Processing::Jobs::RevokedNonBlocking
#initialize Karafka::Processing::ExecutorsBuffer
#initialize Karafka::Processing::Coordinator
#initialize Karafka::Instrumentation::Logger
#initialize Karafka::Instrumentation::Monitor
#initialize Karafka::Instrumentation::Vendors::Datadog::LoggerListener
#initialize Karafka::Processing::JobsQueue
#initialize Karafka::Instrumentation::Notifications
#initialize Karafka::Pro::Encryption::Cipher
#initialize Karafka::Processing::Jobs::Base
#initialize Karafka::TimeTrackers::Pause
#initialize Karafka::Routing::SubscriptionGroupsBuilder
#initialize Karafka::Connection::ConsumerGroupCoordinator
#initialize Karafka::Pro::Processing::StrategySelector
#initialize Karafka::Pro::PerformanceTracker
#initialize Karafka::Processing::CoordinatorsBuffer
jobs_queue Karafka::Server
#kafka Karafka::Routing::SubscriptionGroup
#karafka_options Karafka::ActiveJob::JobExtensions
#key Karafka::Messages::Metadata
#key_location Karafka::Instrumentation::Vendors::Datadog::Listener::RdKafkaMetric
#last Karafka::Messages::Messages
#last_offset Karafka::Messages::BatchMetadata
listeners Karafka::Server
load_all Karafka::Routing::Features::Base
logger Karafka
#long_running_job Karafka::Pro::Routing::Features::LongRunningJob::Topic
#long_running_job? Karafka::Pro::Routing::Features::LongRunningJob::Topic
#lost_partitions Karafka::Connection::RebalanceManager
#manual_offset_management Karafka::Routing::Features::ManualOffsetManagement::Topic
#manual_offset_management? Karafka::Routing::Features::ManualOffsetManagement::Topic
#manual_pause Karafka::Processing::Coordinator
#manual_pause? Karafka::Processing::Coordinator
#mark_as_consumed Karafka::Connection::Client
#mark_as_consumed! Karafka::Connection::Client
#max_messages Karafka::Routing::SubscriptionGroup
#max_partitions Karafka::Pro::Routing::Features::VirtualPartitions::Config
#max_retries Karafka::Routing::Features::DeadLetterQueue::Config
#max_wait_time Karafka::Routing::SubscriptionGroup
#messages Karafka::Processing::Executor
#messages Karafka::BaseConsumer
#messages Karafka::Processing::Jobs::Consume
#metadata Karafka::Messages::Messages
#metadata Karafka::Messages::Message
#method_missing Karafka::Env
monitor Karafka
#name Karafka::Patches::Rdkafka::Consumer
#name Karafka::Routing::ConsumerGroup
#name Karafka::Routing::SubscriptionGroup
#name Karafka::Connection::Client
#name Karafka::Instrumentation::Vendors::Datadog::Listener::RdKafkaMetric
#name Karafka::Routing::Topic
#non_blocking? Karafka::Processing::Jobs::Base
#notifications_bus Karafka::Instrumentation::Monitor
#offset Karafka::Messages::Metadata
#offset Karafka::Messages::Seek
#on_after_consume Karafka::BaseConsumer
#on_app_quiet Karafka::Instrumentation::LoggerListener
#on_app_quieting Karafka::Instrumentation::LoggerListener
#on_app_running Karafka::Instrumentation::LoggerListener
#on_app_stopped Karafka::Instrumentation::LoggerListener
#on_app_stopping Karafka::Instrumentation::LoggerListener
#on_before_consume Karafka::BaseConsumer
#on_before_enqueue Karafka::BaseConsumer
#on_client_pause Karafka::Instrumentation::LoggerListener
#on_client_resume Karafka::Instrumentation::LoggerListener
#on_connection_listener_fetch_loop Karafka::Instrumentation::LoggerListener
#on_connection_listener_fetch_loop_received Karafka::Instrumentation::Vendors::Datadog::Listener
#on_connection_listener_fetch_loop_received Karafka::Instrumentation::LoggerListener
#on_consume Karafka::BaseConsumer
#on_consumer_consumed Karafka::Pro::PerformanceTracker
#on_consumer_consumed Karafka::Instrumentation::Vendors::Datadog::Listener
#on_consumer_consuming_retry Karafka::Instrumentation::LoggerListener
#on_consumer_revoked Karafka::Instrumentation::Vendors::Datadog::Listener
#on_consumer_shutdown Karafka::Instrumentation::Vendors::Datadog::Listener
on_cooperative_rebalance Karafka::Patches::Rdkafka::Bindings
#on_dead_letter_queue_dispatched Karafka::Instrumentation::LoggerListener
on_eager_rebalance Karafka::Patches::Rdkafka::Bindings
#on_enqueued Karafka::Pro::Processing::Coordinator
#on_error_occurred Karafka::Instrumentation::Vendors::Datadog::LoggerListener
#on_error_occurred Karafka::Instrumentation::Vendors::Datadog::Listener
#on_error_occurred Karafka::Instrumentation::LoggerListener
#on_finished Karafka::Pro::Processing::Coordinator
#on_partitions_assigned Karafka::Connection::RebalanceManager
#on_partitions_revoked Karafka::Connection::RebalanceManager
#on_process_notice_signal Karafka::Instrumentation::LoggerListener
#on_revoked Karafka::BaseConsumer
#on_revoked Karafka::Pro::Processing::Coordinator
#on_shutdown Karafka::BaseConsumer
#on_started Karafka::Pro::Processing::Coordinator
#on_statistics_emitted Karafka::Instrumentation::Vendors::Datadog::Listener
#on_worker_process Karafka::Instrumentation::Vendors::Datadog::LoggerListener
#on_worker_process Karafka::Instrumentation::LoggerListener
#on_worker_process Karafka::Instrumentation::Vendors::Datadog::Listener
#on_worker_processed Karafka::Instrumentation::Vendors::Datadog::Listener
#on_worker_processed Karafka::Instrumentation::LoggerListener
#on_worker_processed Karafka::Instrumentation::Vendors::Datadog::LoggerListener
option Karafka::Cli::Base
parser Karafka::Messages::Message
#partition Karafka::Messages::BatchMetadata
#partition Karafka::Messages::Metadata
#partition Karafka::Messages::Seek
#partitioner Karafka::Pro::Routing::Features::VirtualPartitions::Config
#pause Karafka::TimeTrackers::Pause
#pause Karafka::Connection::Client
#pause_tracker Karafka::Processing::Coordinator
#paused? Karafka::TimeTrackers::Pause
#payload Karafka::Messages::Message
#payloads Karafka::Messages::Messages
#ping Karafka::Connection::Client
#pop Karafka::Processing::JobsQueue
#pop_tags Karafka::Instrumentation::Vendors::Datadog::LoggerListener
post_setup Karafka::Pro::Encryption
post_setup Karafka::Pro::Loader
pre_setup Karafka::Pro::Encryption
pre_setup Karafka::Pro::Loader
prepare Karafka::Cli
prepare_and_verify Karafka::Licenser
#prepended Karafka::Routing::Features::Base::Expander
pro? Karafka
#processed_at Karafka::Messages::BatchMetadata
#processing_lag Karafka::Messages::BatchMetadata
#processing_time_p95 Karafka::Pro::PerformanceTracker
producer Karafka::Setup::AttributesMap
#producer Karafka::BaseConsumer
producer Karafka
#push_tags Karafka::Instrumentation::Vendors::Datadog::LoggerListener
quiet Karafka::Embedded
quiet Karafka::Server
#rails? Karafka::Cli::Install
#raw_payload Karafka::Messages::Message
#raw_payloads Karafka::Messages::Messages
read_topic Karafka::Admin
#rebalance_manager Karafka::Connection::Client
#received_at Karafka::Messages::Metadata
#red Karafka::Helpers::Colorize
#reload! Top Level Namespace
#remaining Karafka::TimeTrackers::Poll
#remap Karafka::Connection::MessagesBuffer
require_all Karafka::Pro::Loader
#reset Karafka::TimeTrackers::Pause
#reset Karafka::Connection::Client
#reset Karafka::Processing::CoordinatorsBuffer
#reset! Karafka::Status
#respond_to_missing? Karafka::Routing::Proxy
#respond_to_missing? Karafka::Env
#resume Karafka::Connection::PausesManager
#resume Karafka::TimeTrackers::Pause
#resume Karafka::Connection::Client
#resume Karafka::Processing::CoordinatorsBuffer
#retryable? Karafka::TimeTrackers::Poll
#revoke Karafka::Processing::Coordinator
#revoke Karafka::Processing::CoordinatorsBuffer
#revoke Karafka::Processing::ExecutorsBuffer
#revoked Karafka::Processing::JobsBuilder
#revoked Karafka::Processing::Executor
#revoked Karafka::Pro::Processing::JobsBuilder
#revoked? Karafka::Processing::Coordinator
#revoked_partitions Karafka::Connection::RebalanceManager
root Karafka
run Karafka::Server
#schedule_consumption Karafka::Pro::Processing::Scheduler
#schedule_consumption Karafka::Processing::Scheduler
#scheduled_at Karafka::Messages::BatchMetadata
#scope Karafka::Instrumentation::Vendors::Datadog::Listener::RdKafkaMetric
#seek Karafka::Connection::Client
#seek_offset Karafka::Processing::Coordinator
#setup Karafka::Instrumentation::Vendors::Datadog::Listener
#setup Karafka::Instrumentation::Vendors::Datadog::LoggerListener
setup Karafka::Setup::Config
#setup Karafka::Setup::Dsl
#shutdown Karafka::Processing::JobsBuilder
#shutdown Karafka::Connection::Listener
#shutdown Karafka::Processing::Executor
#shutdown? Karafka::Connection::ConsumerGroupCoordinator
#size Karafka::Processing::WorkersBatch
#size Karafka::Messages::BatchMetadata
#size Karafka::Processing::JobsQueue
#size Karafka::Messages::Messages
#size Karafka::Connection::RawMessagesBuffer
#size Karafka::Connection::MessagesBuffer
#start Karafka::Pro::Processing::Coordinator
#start Karafka::Processing::Coordinator
#start Karafka::TimeTrackers::Poll
start Karafka::Embedded
start Karafka::Server
#statistics Karafka::Processing::JobsQueue
#stop Karafka::Connection::Client
stop Karafka::Embedded
stop Karafka::Server
#store_offset Karafka::Connection::Client
#subscription_group Karafka::Routing::Topic
#subscription_group= Karafka::Routing::ConsumerGroup
#subscription_groups Karafka::Routing::ConsumerGroup
subscription_groups Karafka::App
#success! Karafka::Processing::Result
#success? Karafka::Processing::Coordinator
#success? Karafka::Processing::Result
#supervise Karafka::Process
#supervised? Karafka::Process
#target Karafka::Routing::Proxy
#tick Karafka::Processing::JobsQueue
#timestamp Karafka::Messages::Metadata
#to_a Karafka::Messages::Messages
#to_h Karafka::Routing::ConsumerGroup
#to_h Karafka::Routing::Features::ManualOffsetManagement::Topic
#to_h Karafka::Routing::Features::DeadLetterQueue::Topic
#to_h Karafka::Routing::Topic
#to_h Karafka::Routing::Features::ActiveJob::Topic
#to_h Karafka::Pro::Routing::Features::LongRunningJob::Topic
#to_h Karafka::Pro::Routing::Features::VirtualPartitions::Topic
#to_s Karafka::Status
#topic Karafka::Messages::BatchMetadata
#topic Karafka::Processing::Executor
#topic Karafka::Messages::Metadata
#topic Karafka::Messages::Seek
#topic Karafka::BaseConsumer
#topic Karafka::Routing::Features::DeadLetterQueue::Config
#topic= Karafka::Routing::ConsumerGroup
#topics Karafka::Routing::ConsumerGroup
#topics Karafka::Routing::SubscriptionGroup
trigger_callbacks Karafka::Patches::Rdkafka::Bindings
#type Karafka::Instrumentation::Vendors::Datadog::Listener::RdKafkaMetric
#uniq! Karafka::Connection::RawMessagesBuffer
#unlock Karafka::Connection::ConsumerGroupCoordinator
#validate! Karafka::Contracts::Base
#virtual_partitions Karafka::Pro::Routing::Features::VirtualPartitions::Topic
#virtual_partitions? Karafka::Pro::Routing::Features::VirtualPartitions::Topic
#wait Karafka::Processing::JobsQueue
workers Karafka::Server