Method List
Search:
-
#<< Karafka::Connection::RawMessagesBuffer
-
#<< Karafka::Processing::JobsQueue
-
#action Karafka::Pro::Processing::Filters::Throttler
-
#action Karafka::Pro::Processing::Filters::Base
-
#action Karafka::Pro::Processing::FiltersApplier
-
#action Karafka::Pro::Processing::Filters::Delayer
-
activate Karafka::Routing::Features::Base
-
#active Karafka::Pro::Routing::Features::Delaying::Config
-
#active Karafka::Routing::Builder
-
#active Karafka::Routing::Features::InlineInsights::Config
-
#active Karafka::Routing::Features::Declaratives::Config
-
#active Karafka::Routing::Features::ManualOffsetManagement::Config
-
#active Karafka::Pro::Routing::Features::VirtualPartitions::Config
-
#active Karafka::Routing::Features::DeadLetterQueue::Config
-
#active Karafka::Pro::Routing::Features::Expiring::Config
-
#active Karafka::Pro::Routing::Features::Throttling::Config
-
#active Karafka::Routing::Features::ActiveJob::Config
-
#active Karafka::Pro::Routing::Features::LongRunningJob::Config
-
#active Karafka::Pro::Routing::Features::Patterns::Config
-
#active Karafka::Routing::Topic
-
#active? Karafka::Routing::SubscriptionGroup
-
#active? Karafka::Pro::Routing::Features::Filtering::Config
-
#active? Karafka::Routing::ActivityManager
-
#active? Karafka::Routing::Topic
-
#active? Karafka::Connection::RebalanceManager
-
#active? Karafka::Routing::ConsumerGroup
-
#active_job Karafka::Routing::Features::ActiveJob::Topic
-
#active_job? Karafka::Routing::Features::ActiveJob::Topic
-
#active_job_pattern Karafka::Pro::Routing::Features::ActiveJob::Builder
-
#active_job_topic Karafka::Routing::Features::ActiveJob::Builder
-
#add Karafka::Processing::InlineInsights::Tracker
-
#after_call Karafka::Processing::Jobs::Consume
-
#after_call Karafka::Processing::Jobs::Base
-
#after_consume Karafka::Processing::Executor
-
#applied? Karafka::Pro::Processing::Filters::Base
-
#applied? Karafka::Pro::Processing::FiltersApplier
-
#apply! Karafka::Pro::Processing::Filters::VirtualLimiter
-
#apply! Karafka::Pro::Processing::Filters::Base
-
#apply! Karafka::Pro::Processing::Filters::Expirer
-
#apply! Karafka::Pro::Processing::Filters::Delayer
-
#apply! Karafka::Pro::Processing::Filters::Throttler
-
#apply! Karafka::Pro::Processing::FiltersApplier
-
#assigned_partitions Karafka::Connection::RebalanceManager
-
#assignment_lost? Karafka::Connection::Client
-
#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::Base
-
#before_enqueue Karafka::Processing::Jobs::Consume
-
#before_enqueue Karafka::Processing::Executor
-
bind_to Karafka::Cli::Base
-
boot_file Karafka
-
#build_dlq_message Karafka::Pro::Processing::Strategies::Dlq::Default
-
#call Karafka::Routing::SubscriptionGroupsBuilder
-
#call Karafka::Processing::Jobs::Consume
-
#call Karafka::Cli::Base
-
#call Karafka::Pro::Iterator::Expander
-
#call Karafka::Cli::Console
-
#call Karafka::Cli::Server
-
#call Karafka::Cli::Topics
-
#call Karafka::Cli::Info
-
#call Karafka::Pro::Iterator::TplBuilder
-
#call Karafka::Instrumentation::Callbacks::Statistics
-
#call Karafka::Cli::Install
-
#call Karafka::Pro::Encryption::Messages::Middleware
-
#call Karafka::Instrumentation::Callbacks::Error
-
#call Karafka::Runner
-
#call Karafka::Connection::Listener
-
call Karafka::Messages::Builders::Message
-
#call Karafka::Messages::Parser
-
#call Karafka::Processing::Jobs::Base
-
#call Karafka::Pro::Encryption::Messages::Parser
-
#call Karafka::Processing::Jobs::Revoked
-
#call Karafka::Pro::Processing::Partitioner
-
#call Karafka::Routing::ConsumerMapper
-
#call Karafka::Processing::Jobs::Shutdown
-
#call Karafka::Processing::Jobs::Idle
-
#call Karafka::Processing::Partitioner
-
#call Karafka::Serialization::Json::Deserializer
-
call Karafka::Messages::Builders::BatchMetadata
-
call Karafka::Messages::Builders::Messages
-
#cause Karafka::Processing::Result
-
#changed? Karafka::Connection::RebalanceManager
-
#checkpoint Karafka::TimeTrackers::Poll
-
#clean! Karafka::Pro::Cleaner::Messages::Message
-
#cleaned? Karafka::Pro::Cleaner::Messages::Message
-
#clear Karafka::Routing::Builder
-
#clear Karafka::Connection::RebalanceManager
-
#clear Karafka::Connection::RawMessagesBuffer
-
#clear Karafka::Processing::ExecutorsBuffer
-
#clear Karafka::Routing::ActivityManager
-
#clear Karafka::Pro::Processing::VirtualOffsetManager
-
#clear Karafka::Processing::InlineInsights::Tracker
-
#clear Karafka::Processing::JobsQueue
-
#cli Karafka::Cli::Base
-
#client Karafka::BaseConsumer
-
#close Karafka::Processing::JobsQueue
-
cluster_info Karafka::Admin
-
#collapse_until! Karafka::Pro::Processing::Collapser
-
#collapsed? Karafka::Pro::Processing::Strategies::Vp::Default
-
#collapsed? Karafka::Pro::Processing::Collapser
-
#collapsed? Karafka::Pro::Processing::Coordinator
-
#commit_offsets Karafka::Connection::Client
-
#commit_offsets Karafka::Processing::Strategies::Default
-
#commit_offsets! Karafka::Connection::Client
-
#commit_offsets! Karafka::Processing::Strategies::Default
-
#complete Karafka::Processing::JobsQueue
-
#config Karafka::Setup::Dsl
-
#config Karafka::Routing::Features::Declaratives::Topic
-
#config Karafka::Pro::Routing::Features::Patterns::Pattern
-
console Karafka::Cli::Console
-
#consume Karafka::ActiveJob::Consumer
-
#consume Karafka::Pro::Processing::JobsBuilder
-
#consume Karafka::Pro::ActiveJob::Consumer
-
#consume Karafka::Processing::JobsBuilder
-
#consume Karafka::Processing::Executor
-
#consumer Karafka::Routing::Topic
-
consumer Karafka::Setup::AttributesMap
-
#consumer_class Karafka::Routing::Topic
-
#consumer_group Karafka::Routing::Topic
-
#consumer_group Karafka::Routing::SubscriptionGroup
-
#consumer_group_id Karafka::Routing::SubscriptionGroup
-
consumer_groups Karafka::App
-
#consumption_lag Karafka::Messages::BatchMetadata
-
#coordinator Karafka::BaseConsumer
-
#coordinator Karafka::Processing::Executor
-
#coordinators Karafka::Connection::ListenersBatch
-
core_root Karafka
-
create_partitions Karafka::Admin
-
create_topic Karafka::Admin
-
#created_at Karafka::Messages::BatchMetadata
-
#current_subscription_group_name Karafka::Routing::ConsumerGroup
-
#current_timeout Karafka::TimeTrackers::Pause
-
#cursor Karafka::Pro::Processing::FiltersApplier
-
#cursor Karafka::Pro::Processing::Filters::Base
-
#dead_letter_queue Karafka::Routing::Features::DeadLetterQueue::Topic
-
#dead_letter_queue? Karafka::Routing::Features::DeadLetterQueue::Topic
-
#declaratives Karafka::Routing::Features::Declaratives::Topic
-
#declaratives? Karafka::Routing::Features::Declaratives::Topic
-
#decrement Karafka::Processing::Coordinator
-
#decrypt Karafka::Pro::Encryption::Cipher
-
#defaults Karafka::Routing::Builder
-
#delay Karafka::Pro::Routing::Features::Delaying::Config
-
#delay_by Karafka::Pro::Routing::Features::Delaying::Topic
-
#delaying Karafka::Pro::Routing::Features::Delaying::Topic
-
#delaying? Karafka::Pro::Routing::Features::Delaying::Topic
-
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::BatchMetadata
-
#deserializer Karafka::Messages::Metadata
-
#details Karafka::Routing::Features::Declaratives::Config
-
detect Karafka::Licenser
-
#discovered? Karafka::Pro::Routing::Features::Patterns::Config
-
#dispatch Karafka::ActiveJob::Dispatcher
-
#dispatch Karafka::Pro::ActiveJob::Dispatcher
-
#dispatch_many Karafka::Pro::ActiveJob::Dispatcher
-
#dispatch_many Karafka::ActiveJob::Dispatcher
-
#dispatch_to_dlq Karafka::Pro::Processing::Strategies::Dlq::Default
-
#dispatch_to_dlq Karafka::Processing::Strategies::Dlq
-
#dispatch_to_dlq? Karafka::Pro::Processing::Strategies::Dlq::Default
-
#done? Karafka::Status
-
done? Karafka::App
-
#draw Karafka::Routing::Builder
-
#each Karafka::Messages::Messages
-
#each Karafka::Connection::MessagesBuffer
-
#each Karafka::Pro::Cleaner::Messages::Messages
-
#each Karafka::Connection::ListenersBatch
-
#each Karafka::Routing::Topics
-
#each Karafka::Connection::RawMessagesBuffer
-
#each Karafka::Pro::Iterator
-
#each Karafka::Processing::WorkersBatch
-
#each Karafka::Processing::ExecutorsBuffer
-
#empty? Karafka::Messages::Messages
-
#empty? Karafka::Processing::JobsQueue
-
#empty? Karafka::Connection::MessagesBuffer
-
#encrypt Karafka::Pro::Encryption::Cipher
-
#enqueue ActiveJob::QueueAdapters::KarafkaAdapter
-
#enqueue_all ActiveJob::QueueAdapters::KarafkaAdapter
-
#enqueue_at ActiveJob::QueueAdapters::KarafkaAdapter
-
env Karafka
-
env= Karafka
-
#exceeded? Karafka::TimeTrackers::Poll
-
#exclude Karafka::Routing::ActivityManager
-
#executor Karafka::Processing::Jobs::Base
-
#exists? Karafka::Processing::InlineInsights::Tracker
-
#expand Karafka::Pro::Routing::Features::Patterns::Detector
-
#expire Karafka::TimeTrackers::Pause
-
#expire_in Karafka::Pro::Routing::Features::Expiring::Topic
-
#expired? Karafka::TimeTrackers::Pause
-
#expiring Karafka::Pro::Routing::Features::Expiring::Topic
-
#expiring? Karafka::Pro::Routing::Features::Expiring::Topic
-
extended Karafka::ActiveJob::JobExtensions
-
#factories Karafka::Pro::Routing::Features::Filtering::Config
-
#failing? Karafka::Pro::Processing::Strategies::Vp::Default
-
#failure! Karafka::Processing::Result
-
#failure! Karafka::Processing::Coordinator
-
#failure! Karafka::Pro::Processing::Coordinator
-
#failure? Karafka::Processing::Result
-
#failure? Karafka::Processing::Coordinator
-
#fetch Karafka::Connection::PausesManager
-
#filter Karafka::Pro::Processing::Coordinator
-
#filter Karafka::Pro::Routing::Features::Filtering::Topic
-
#filtered? Karafka::Pro::Processing::Coordinator
-
#filtering Karafka::Pro::Routing::Features::Filtering::Topic
-
#filtering? Karafka::Pro::Routing::Features::Filtering::Topic
-
#filters Karafka::Pro::Processing::FiltersApplier
-
#filters Karafka::Pro::Routing::Features::Filtering::Config
-
#find Karafka::Pro::Routing::Features::Patterns::Patterns
-
#find Karafka::Processing::StrategySelector
-
#find Karafka::Routing::Topics
-
#find Karafka::Processing::InlineInsights::Tracker
-
#find Karafka::Pro::Routing::Features::Patterns::Topics
-
#find Karafka::Processing::ExpansionsSelector
-
#find Karafka::Pro::Processing::StrategySelector
-
#find_all Karafka::Processing::ExecutorsBuffer
-
find_by Karafka::Routing::Router
-
#find_or_create Karafka::Processing::CoordinatorsBuffer
-
#find_or_create Karafka::Processing::ExecutorsBuffer
-
find_or_initialize_by_name Karafka::Routing::Router
-
#find_skippable_message Karafka::Processing::Strategies::Dlq
-
#find_skippable_message Karafka::Pro::Processing::Strategies::Dlq::Default
-
#finish_work Karafka::Connection::ConsumerGroupCoordinator
-
#finished? Karafka::Connection::ConsumerGroupCoordinator
-
#finished? Karafka::Pro::Processing::Coordinator
-
#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
-
#groups Karafka::Pro::Processing::VirtualOffsetManager
-
#handle_after_consume Karafka::Pro::Processing::Strategies::Aj::FtrMomVp
-
#handle_after_consume Karafka::Pro::Processing::Strategies::Dlq::LrjMom
-
#handle_after_consume Karafka::Pro::Processing::Strategies::Aj::DlqFtrLrjMomVp
-
#handle_after_consume Karafka::Pro::Processing::Strategies::Aj::DlqFtrMomVp
-
#handle_after_consume Karafka::Pro::Processing::Strategies::Mom::Ftr
-
#handle_after_consume Karafka::Processing::Strategies::Base
-
#handle_after_consume Karafka::Processing::Strategies::Mom
-
#handle_after_consume Karafka::Pro::Processing::Strategies::Aj::FtrLrjMomVp
-
#handle_after_consume Karafka::Pro::Processing::Strategies::Dlq::FtrLrj
-
#handle_after_consume Karafka::Pro::Processing::Strategies::Dlq::Mom
-
#handle_after_consume Karafka::Pro::Processing::Strategies::Lrj::Mom
-
#handle_after_consume Karafka::Processing::Strategies::Default
-
#handle_after_consume Karafka::Pro::Processing::Strategies::Ftr::Default
-
#handle_after_consume Karafka::Pro::Processing::Strategies::Aj::DlqLrjMom
-
#handle_after_consume Karafka::Processing::Strategies::DlqMom
-
#handle_after_consume Karafka::Pro::Processing::Strategies::Lrj::Ftr
-
#handle_after_consume Karafka::Pro::Processing::Strategies::Aj::DlqLrjMomVp
-
#handle_after_consume Karafka::Pro::Processing::Strategies::Aj::DlqMomVp
-
#handle_after_consume Karafka::Pro::Processing::Strategies::Dlq::Default
-
#handle_after_consume Karafka::Pro::Processing::Strategies::Aj::DlqMom
-
#handle_after_consume Karafka::Pro::Processing::Strategies::Aj::LrjMomVp
-
#handle_after_consume Karafka::Processing::Strategies::AjDlqMom
-
#handle_after_consume Karafka::Pro::Processing::Strategies::Dlq::Ftr
-
#handle_after_consume Karafka::Pro::Processing::Strategies::Dlq::FtrMom
-
#handle_after_consume Karafka::Pro::Processing::Strategies::Default
-
#handle_after_consume Karafka::Pro::Processing::Strategies::Lrj::Default
-
#handle_after_consume Karafka::Pro::Processing::Strategies::Lrj::FtrMom
-
#handle_after_consume Karafka::Pro::Processing::Strategies::Mom::Default
-
#handle_after_consume Karafka::Processing::Strategies::Dlq
-
#handle_after_consume Karafka::Pro::Processing::Strategies::Dlq::FtrLrjMom
-
#handle_after_consume Karafka::Pro::Processing::Strategies::Aj::MomVp
-
#handle_after_consume Karafka::Pro::Processing::Strategies::Dlq::Lrj
-
#handle_after_consume Karafka::Pro::Processing::Strategies::Aj::DlqFtrLrjMom
-
#handle_after_consume Karafka::Pro::Processing::Strategies::Aj::DlqFtrMom
-
#handle_before_consume Karafka::Processing::Strategies::Base
-
#handle_before_consume Karafka::Processing::Strategies::Default
-
#handle_before_consume Karafka::Pro::Processing::Strategies::Default
-
#handle_before_enqueue Karafka::Processing::Strategies::Base
-
#handle_before_enqueue Karafka::Pro::Processing::Strategies::Default
-
#handle_before_enqueue Karafka::Pro::Processing::Strategies::Lrj::Mom
-
#handle_before_enqueue Karafka::Pro::Processing::Strategies::Aj::LrjMomVp
-
#handle_before_enqueue Karafka::Processing::Strategies::Default
-
#handle_before_enqueue Karafka::Pro::Processing::Strategies::Lrj::Default
-
#handle_consume Karafka::Processing::Strategies::Base
-
#handle_consume Karafka::Processing::Strategies::Default
-
#handle_consume Karafka::Pro::Processing::Strategies::Default
-
#handle_idle Karafka::Pro::Processing::Strategies::Ftr::Default
-
#handle_idle Karafka::Processing::Strategies::Base
-
#handle_idle Karafka::Processing::Strategies::Default
-
#handle_post_filtering Karafka::Pro::Processing::Strategies::Ftr::Default
-
#handle_revoked Karafka::Pro::Processing::Strategies::Lrj::Default
-
#handle_revoked Karafka::Processing::Strategies::Default
-
#handle_revoked Karafka::Pro::Processing::Strategies::Lrj::Mom
-
#handle_revoked Karafka::Processing::Strategies::Base
-
#handle_revoked Karafka::Pro::Processing::Strategies::Default
-
#handle_revoked Karafka::Pro::Processing::Strategies::Aj::LrjMomVp
-
#handle_shutdown Karafka::Processing::Strategies::Default
-
#handle_shutdown Karafka::Processing::Strategies::Base
-
#headers Karafka::Messages::Metadata
-
#id Karafka::Routing::ConsumerGroup
-
id Karafka::Routing::SubscriptionGroup
-
#id Karafka::Processing::Executor
-
#id Karafka::Connection::Listener
-
#id Karafka::Processing::Worker
-
#id Karafka::Connection::Client
-
#id Karafka::Routing::SubscriptionGroup
-
#id Karafka::Routing::Topic
-
#id Karafka::BaseConsumer
-
#idle Karafka::Processing::Executor
-
#idle Karafka::Pro::Processing::JobsBuilder
-
#include Karafka::Routing::ActivityManager
-
included Karafka::Helpers::Async
-
#increment Karafka::Processing::Coordinator
-
#increment Karafka::TimeTrackers::Pause
-
#initialize Karafka::Helpers::MultiDelegator
-
#initialize Karafka::Routing::ConsumerGroup
-
#initialize Karafka::Processing::Partitioner
-
#initialize Karafka::Processing::Coordinator
-
#initialize Karafka::Instrumentation::Logger
-
#initialize Karafka::Processing::JobsQueue
-
#initialize Karafka::Instrumentation::Monitor
-
#initialize Karafka::Connection::ConsumerGroupCoordinator
-
#initialize Karafka::Pro::Encryption::Cipher
-
#initialize Karafka::Processing::Jobs::Idle
-
#initialize Karafka::Pro::Processing::Filters::VirtualLimiter
-
#initialize Karafka::TimeTrackers::Pause
-
#initialize Karafka::Processing::Jobs::Base
-
#initialize Karafka::Processing::Executor
-
#initialize Karafka::Connection::Listener
-
#initialize Karafka::TimeTrackers::Poll
-
#initialize Karafka::Processing::Worker
-
#initialize Karafka::Pro::Processing::Filters::Base
-
#initialize Karafka::Processing::Result
-
#initialize Karafka::Instrumentation::Vendors::Datadog::MetricsListener
-
#initialize Karafka::Instrumentation::Notifications
-
#initialize Karafka::Messages::Messages
-
#initialize Karafka::Pro::Processing::Jobs::RevokedNonBlocking
-
#initialize Karafka::Connection::Client
-
#initialize Karafka::Processing::ExecutorsBuffer
-
#initialize Karafka::Pro::Processing::Filters::Throttler
-
#initialize Karafka::Messages::Message
-
#initialize Karafka::Connection::Proxy
-
#initialize Karafka::Routing::Builder
-
#initialize Karafka::Routing::Topics
-
#initialize Karafka::Pro::Routing::Features::Patterns::ConsumerGroup
-
#initialize Karafka::Routing::Topic
-
#initialize Karafka::Pro::Processing::Jobs::ConsumeNonBlocking
-
#initialize Karafka::Routing::Proxy
-
#initialize Karafka::Instrumentation::Vendors::Datadog::LoggerListener
-
#initialize Karafka::Pro::Processing::Filters::Expirer
-
#initialize Karafka::Pro::Processing::FiltersApplier
-
#initialize Karafka::BaseConsumer
-
#initialize Karafka::Pro::Iterator
-
#initialize Karafka::Routing::Features::Base::Expander
-
#initialize Karafka::Cli::Install
-
#initialize Karafka::Cli::Base
-
#initialize Karafka::Status
-
#initialize Karafka::Process
-
#initialize Karafka::Processing::InlineInsights::Tracker
-
#initialize Karafka::Env
-
#initialize Karafka::Routing::SubscriptionGroupsBuilder
-
#initialize Karafka::Instrumentation::Callbacks::Error
-
#initialize Karafka::Processing::CoordinatorsBuffer
-
#initialize Karafka::Pro::Processing::Coordinator
-
#initialize Karafka::Routing::SubscriptionGroup
-
#initialize Karafka::Connection::MessagesBuffer
-
#initialize Karafka::Instrumentation::Vendors::Kubernetes::LivenessListener
-
#initialize Karafka::Connection::ListenersBatch
-
#initialize Karafka::Pro::Processing::VirtualOffsetManager
-
#initialize Karafka::Routing::ActivityManager
-
#initialize Karafka::Connection::PausesManager
-
#initialize Karafka::Connection::RawMessagesBuffer
-
#initialize Karafka::Processing::Jobs::Shutdown
-
#initialize Karafka::Processing::WorkersBatch
-
#initialize Karafka::Pro::Processing::Collapser
-
#initialize Karafka::Pro::Iterator::TplBuilder
-
#initialize Karafka::Pro::Processing::Filters::Delayer
-
#initialize Karafka::Processing::Jobs::Revoked
-
#initialize Karafka::Processing::Jobs::Consume
-
#initialize Karafka::Pro::PerformanceTracker
-
#initialize Karafka::Processing::StrategySelector
-
#initialize Karafka::Pro::Routing::Features::Patterns::Pattern
-
#initialize Karafka::Instrumentation::Callbacks::Statistics
-
#initialize Karafka::Connection::RebalanceManager
-
#initialize Karafka::Pro::Processing::StrategySelector
-
#inline_insights Karafka::Routing::Features::InlineInsights::Topic
-
#inline_insights? Karafka::Routing::Features::InlineInsights::Topic
-
#insights Karafka::Processing::InlineInsights::Consumer
-
#insights? Karafka::Processing::InlineInsights::Consumer
-
#interval Karafka::Pro::Routing::Features::Throttling::Config
-
jobs_queue Karafka::Server
-
#kafka Karafka::Routing::SubscriptionGroup
-
#karafka_options Karafka::ActiveJob::JobExtensions
-
#key Karafka::Messages::Metadata
-
#key_location Karafka::Instrumentation::Vendors::Datadog::MetricsListener::RdKafkaMetric
-
#last Karafka::Messages::Messages
-
#last_offset Karafka::Messages::BatchMetadata
-
#limit Karafka::Pro::Routing::Features::Throttling::Config
-
listeners Karafka::Server
-
load Karafka::Cli::Base
-
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
-
#manual_seek Karafka::Processing::Coordinator
-
#manual_seek? Karafka::Processing::Coordinator
-
#mark Karafka::Pro::Processing::VirtualOffsetManager
-
#mark_as_consumed Karafka::Connection::Client
-
#mark_as_consumed Karafka::Processing::Strategies::Default
-
#mark_as_consumed Karafka::Pro::Processing::Strategies::Vp::Default
-
#mark_as_consumed! Karafka::Connection::Client
-
#mark_as_consumed! Karafka::Pro::Processing::Strategies::Vp::Default
-
#mark_as_consumed! Karafka::Processing::Strategies::Default
-
#mark_until Karafka::Pro::Processing::VirtualOffsetManager
-
#markable Karafka::Pro::Processing::VirtualOffsetManager
-
#markable? Karafka::Pro::Processing::VirtualOffsetManager
-
#marked Karafka::Pro::Processing::VirtualOffsetManager
-
#marked? Karafka::Processing::Coordinator
-
#matcher? Karafka::Pro::Routing::Features::Patterns::Config
-
#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::Routing::ConsumerGroup
-
#name Karafka::Connection::Client
-
#name Karafka::Pro::Routing::Features::Patterns::Pattern
-
#name Karafka::Instrumentation::Vendors::Datadog::MetricsListener::RdKafkaMetric
-
#name Karafka::Routing::Topic
-
#name Karafka::Routing::SubscriptionGroup
-
#non_blocking? Karafka::Processing::Jobs::Base
-
#notifications_bus Karafka::Instrumentation::Monitor
-
#offset Karafka::Messages::Metadata
-
#offset Karafka::Messages::Seek
-
#offsets_for_times Karafka::Connection::Proxy
-
#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::Vendors::Kubernetes::LivenessListener
-
#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::Vendors::Kubernetes::LivenessListener
-
#on_connection_listener_fetch_loop Karafka::Instrumentation::LoggerListener
-
#on_connection_listener_fetch_loop_received Karafka::Instrumentation::Vendors::Datadog::MetricsListener
-
#on_connection_listener_fetch_loop_received Karafka::Instrumentation::LoggerListener
-
#on_consume Karafka::BaseConsumer
-
#on_consumer_consume Karafka::Instrumentation::Vendors::Kubernetes::LivenessListener
-
#on_consumer_consumed Karafka::Instrumentation::Vendors::Kubernetes::LivenessListener
-
#on_consumer_consumed Karafka::Pro::PerformanceTracker
-
#on_consumer_consumed Karafka::Instrumentation::Vendors::Datadog::MetricsListener
-
#on_consumer_consuming_retry Karafka::Instrumentation::LoggerListener
-
#on_consumer_revoke Karafka::Instrumentation::Vendors::Kubernetes::LivenessListener
-
#on_consumer_revoked Karafka::Instrumentation::Vendors::Kubernetes::LivenessListener
-
#on_consumer_revoked Karafka::Instrumentation::Vendors::Datadog::MetricsListener
-
#on_consumer_shutdown Karafka::Instrumentation::Vendors::Kubernetes::LivenessListener
-
#on_consumer_shutdown Karafka::Instrumentation::Vendors::Datadog::MetricsListener
-
#on_consumer_shutting_down Karafka::Instrumentation::Vendors::Kubernetes::LivenessListener
-
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::LoggerListener
-
#on_error_occurred Karafka::Instrumentation::Vendors::Datadog::MetricsListener
-
#on_error_occurred Karafka::Instrumentation::Vendors::Kubernetes::LivenessListener
-
#on_filtering_seek Karafka::Instrumentation::LoggerListener
-
#on_filtering_throttled Karafka::Instrumentation::LoggerListener
-
#on_finished Karafka::Pro::Processing::Coordinator
-
#on_idle Karafka::BaseConsumer
-
#on_partitions_assigned Karafka::Connection::RebalanceManager
-
#on_partitions_revoked Karafka::Connection::RebalanceManager
-
#on_process_notice_signal Karafka::Instrumentation::LoggerListener
-
#on_revoked Karafka::Pro::Processing::Coordinator
-
#on_revoked Karafka::BaseConsumer
-
#on_shutdown Karafka::BaseConsumer
-
#on_started Karafka::Pro::Processing::Coordinator
-
#on_statistics_emitted Karafka::Instrumentation::Vendors::Datadog::MetricsListener
-
#on_statistics_emitted Karafka::Processing::InlineInsights::Listener
-
#on_worker_process Karafka::Instrumentation::Vendors::Datadog::MetricsListener
-
#on_worker_process Karafka::Instrumentation::LoggerListener
-
#on_worker_process Karafka::Instrumentation::Vendors::Datadog::LoggerListener
-
#on_worker_processed Karafka::Instrumentation::Vendors::Datadog::LoggerListener
-
#on_worker_processed Karafka::Instrumentation::Vendors::Datadog::MetricsListener
-
#on_worker_processed Karafka::Instrumentation::LoggerListener
-
option Karafka::Cli::Base
-
parser Karafka::Messages::Message
-
#partition Karafka::Messages::BatchMetadata
-
#partition Karafka::Processing::Coordinator
-
#partition Karafka::Messages::Metadata
-
#partition Karafka::Messages::Seek
-
#partitioner Karafka::Pro::Routing::Features::VirtualPartitions::Config
-
#partitions Karafka::Routing::Features::Declaratives::Config
-
#pattern Karafka::Pro::Routing::Features::Patterns::Builder
-
#pattern Karafka::Pro::Routing::Features::Patterns::Config
-
#pattern= Karafka::Pro::Routing::Features::Patterns::ConsumerGroup
-
#patterns Karafka::Pro::Routing::Features::Patterns::Topic
-
#patterns Karafka::Pro::Routing::Features::Patterns::ConsumerGroup
-
#patterns? Karafka::Pro::Routing::Features::Patterns::Topic
-
#pause Karafka::TimeTrackers::Pause
-
#pause Karafka::Pro::Routing::Features::Pausing::Topic
-
#pause Karafka::Connection::Client
-
#pause_tracker Karafka::Processing::Coordinator
-
#paused? Karafka::TimeTrackers::Pause
-
#payload Karafka::Pro::Cleaner::Messages::Message
-
#payload Karafka::Messages::Message
-
#payloads Karafka::Messages::Messages
-
persist Karafka::ActiveJob::CurrentAttributes
-
#ping Karafka::Connection::Client
-
#pop Karafka::Processing::JobsQueue
-
#pop_tags Karafka::Instrumentation::Vendors::Datadog::LoggerListener
-
post_setup Karafka::Routing::Features::InlineInsights
-
post_setup Karafka::Pro::Encryption
-
post_setup Karafka::Pro::Cleaner
-
post_setup_all Karafka::Routing::Features::Base
-
post_setup_all Karafka::Pro::Loader
-
pre_setup Karafka::Pro::Encryption
-
pre_setup Karafka::Pro::Cleaner
-
pre_setup_all Karafka::Routing::Features::Base
-
pre_setup_all 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
-
#query_watermark_offsets Karafka::Connection::Proxy
-
quiet Karafka::Embedded
-
quiet Karafka::Server
-
#rails? Karafka::Cli::Install
-
rails? Karafka
-
rails_console Karafka::Cli::Console
-
#raw_payload Karafka::Messages::Message
-
#raw_payloads Karafka::Messages::Messages
-
read_topic Karafka::Admin
-
read_watermark_offsets Karafka::Admin
-
#rebalance_manager Karafka::Connection::Client
-
#received_at Karafka::Messages::Metadata
-
#red Karafka::Helpers::Colorize
-
#refresh! Karafka::Pro::Processing::Collapser
-
refresh! Karafka
-
#regexp Karafka::Pro::Routing::Features::Patterns::Pattern
-
#regexp_string Karafka::Pro::Routing::Features::Patterns::Pattern
-
#register Karafka::Pro::Processing::VirtualOffsetManager
-
#regular? Karafka::Pro::Routing::Features::Patterns::Config
-
#reload! Top Level Namespace
-
#remaining Karafka::TimeTrackers::Poll
-
#remap Karafka::Connection::MessagesBuffer
-
#replication_factor Karafka::Routing::Features::Declaratives::Config
-
require_all Karafka::Pro::Loader
-
#reset Karafka::Processing::CoordinatorsBuffer
-
#reset Karafka::TimeTrackers::Pause
-
#reset Karafka::Connection::Client
-
#reset! Karafka::Status
-
#respond_to_missing? Karafka::Routing::Proxy
-
#respond_to_missing? Karafka::Env
-
#resume Karafka::Processing::CoordinatorsBuffer
-
#resume Karafka::Connection::PausesManager
-
#resume Karafka::TimeTrackers::Pause
-
#resume Karafka::Connection::Client
-
#retryable? Karafka::TimeTrackers::Poll
-
#revoke Karafka::Processing::CoordinatorsBuffer
-
#revoke Karafka::Processing::ExecutorsBuffer
-
#revoke Karafka::Processing::Coordinator
-
#revoked Karafka::Pro::Processing::JobsBuilder
-
#revoked Karafka::Processing::JobsBuilder
-
#revoked Karafka::Processing::Executor
-
#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::MetricsListener::RdKafkaMetric
-
#seek Karafka::Connection::Client
-
#seek_offset Karafka::Processing::Coordinator
-
#serialize_job Karafka::ActiveJob::CurrentAttributes::Persistence
-
#setup Karafka::Instrumentation::Vendors::Datadog::MetricsListener
-
setup Karafka::Setup::Config
-
#setup Karafka::Setup::Dsl
-
#setup Karafka::Instrumentation::Vendors::Datadog::LoggerListener
-
#shutdown Karafka::Processing::JobsBuilder
-
#shutdown Karafka::Processing::Executor
-
#shutdown Karafka::Connection::Listener
-
#shutdown? Karafka::Connection::ConsumerGroupCoordinator
-
#size Karafka::Connection::RawMessagesBuffer
-
#size Karafka::Connection::MessagesBuffer
-
#size Karafka::Processing::WorkersBatch
-
#size Karafka::Processing::JobsQueue
-
#size Karafka::Messages::Messages
-
#size Karafka::Messages::BatchMetadata
-
#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
-
#stop_current_partition Karafka::Pro::Iterator
-
#stop_partition Karafka::Pro::Iterator
-
#store_offset Karafka::Connection::Client
-
#strategies Karafka::Processing::StrategySelector
-
#strategies Karafka::Pro::Processing::StrategySelector
-
#subscription_group Karafka::Routing::Topic
-
#subscription_group= Karafka::Routing::ConsumerGroup
-
#subscription_group_name Karafka::Routing::Topic
-
#subscription_groups Karafka::Routing::ConsumerGroup
-
subscription_groups Karafka::App
-
#subscription_name Karafka::Pro::Routing::Features::Patterns::Topic
-
#subscription_name Karafka::Routing::Topic
-
#subscriptions Karafka::Routing::SubscriptionGroup
-
#success! Karafka::Processing::Coordinator
-
#success! Karafka::Processing::Result
-
#success? Karafka::Processing::Coordinator
-
#success? Karafka::Processing::Result
-
#supervise Karafka::Process
-
#supervised? Karafka::Process
-
#synchronize Karafka::Processing::Coordinator
-
#target Karafka::Routing::Proxy
-
#throttle Karafka::Pro::Routing::Features::Throttling::Topic
-
#throttling Karafka::Pro::Routing::Features::Throttling::Topic
-
#throttling? Karafka::Pro::Routing::Features::Throttling::Topic
-
#tick Karafka::Processing::JobsQueue
-
#timeout Karafka::Pro::Processing::FiltersApplier
-
#timeout Karafka::Pro::Processing::Filters::Delayer
-
#timeout Karafka::Pro::Processing::Filters::Base
-
#timeout Karafka::Pro::Processing::Filters::Throttler
-
#timestamp Karafka::Messages::Metadata
-
#to_a Karafka::Messages::Messages
-
#to_h Karafka::Routing::ActivityManager
-
#to_h Karafka::Routing::ConsumerGroup
-
#to_h Karafka::Routing::Features::ManualOffsetManagement::Topic
-
#to_h Karafka::Routing::Topic
-
#to_h Karafka::Routing::Features::DeadLetterQueue::Topic
-
#to_h Karafka::Routing::Features::InlineInsights::Topic
-
#to_h Karafka::Pro::Routing::Features::Patterns::Pattern
-
#to_h Karafka::Pro::Routing::Features::Filtering::Config
-
#to_h Karafka::Pro::Routing::Features::Throttling::Topic
-
#to_h Karafka::Pro::Routing::Features::Filtering::Topic
-
#to_h Karafka::Routing::Features::Declaratives::Topic
-
#to_h Karafka::Pro::Routing::Features::Expiring::Topic
-
#to_h Karafka::Pro::Routing::Features::Delaying::Topic
-
#to_h Karafka::Routing::Features::ActiveJob::Topic
-
#to_h Karafka::Pro::Routing::Features::Patterns::Topic
-
#to_h Karafka::Pro::Routing::Features::VirtualPartitions::Topic
-
#to_h Karafka::Pro::Routing::Features::Patterns::ConsumerGroup
-
#to_h Karafka::Pro::Routing::Features::LongRunningJob::Topic
-
#to_s Karafka::Routing::SubscriptionGroup
-
#to_s Karafka::Status
-
#topic Karafka::Messages::BatchMetadata
-
#topic Karafka::Processing::Coordinator
-
#topic Karafka::Messages::Metadata
-
#topic Karafka::Messages::Seek
-
#topic Karafka::Routing::Features::DeadLetterQueue::Config
-
#topic Karafka::Pro::Routing::Features::Patterns::Pattern
-
#topic= Karafka::Routing::ConsumerGroup
-
#topics Karafka::Routing::SubscriptionGroup
-
#topics Karafka::Routing::ConsumerGroup
-
trigger_callbacks Karafka::Patches::Rdkafka::Bindings
-
#ttl Karafka::Pro::Routing::Features::Expiring::Config
-
#type Karafka::Pro::Routing::Features::Patterns::Config
-
#type Karafka::Instrumentation::Vendors::Datadog::MetricsListener::RdKafkaMetric
-
#uniq! Karafka::Connection::RawMessagesBuffer
-
#unlock Karafka::Connection::ConsumerGroupCoordinator
-
#validate! Karafka::Contracts::Base
-
#virtual_offset_manager Karafka::Pro::Processing::Coordinator
-
#virtual_partitions Karafka::Pro::Routing::Features::VirtualPartitions::Topic
-
#virtual_partitions? Karafka::Pro::Routing::Features::VirtualPartitions::Topic
-
#wait Karafka::Processing::JobsQueue
-
with_consumer Karafka::Admin
-
#with_deserialized_job Karafka::ActiveJob::CurrentAttributes::Loading
-
workers Karafka::Server
-
#wrapped Karafka::Connection::Proxy
-
#yellow Karafka::Helpers::Colorize