Method List

Classes Methods Files

Search:

#<< Karafka::Processing::JobsQueue
#<< Karafka::Pro::RecurringTasks::Schedule
#<< Karafka::Connection::RawMessagesBuffer
#<< Karafka::Pro::ScheduledMessages::Dispatcher
#<< Karafka::Pro::ScheduledMessages::DailyBuffer
#<< Karafka::Pro::Processing::Coordinators::ErrorsTracker
#action Karafka::Pro::Processing::Filters::Base
#action Karafka::Pro::Processing::Filters::Delayer
#action Karafka::Pro::Processing::Filters::Throttler
#action Karafka::Pro::Processing::Coordinators::FiltersApplier
#action Karafka::Pro::Processing::Filters::InlineInsightsDelayer
activate Karafka::Routing::Features::Base
#active Karafka::Routing::Topic
#active Karafka::Routing::Builder
#active Karafka::Connection::ListenersBatch
#active Karafka::Routing::Features::Eofed::Config
#active Karafka::Pro::Routing::Features::Swarm::Config
#active Karafka::Routing::Features::ActiveJob::Config
#active Karafka::Pro::Routing::Features::Delaying::Config
#active Karafka::Pro::Routing::Features::Expiring::Config
#active Karafka::Pro::Routing::Features::Patterns::Config
#active Karafka::Routing::Features::Declaratives::Config
#active Karafka::Routing::Features::Deserializers::Config
#active Karafka::Pro::Routing::Features::Throttling::Config
#active Karafka::Routing::Features::InlineInsights::Config
#active Karafka::Pro::Routing::Features::Multiplexing::Config
#active Karafka::Pro::Routing::Features::PeriodicJob::Config
#active Karafka::Routing::Features::DeadLetterQueue::Config
#active Karafka::Pro::Routing::Features::InlineInsights::Config
#active Karafka::Pro::Routing::Features::OffsetMetadata::Config
#active Karafka::Pro::Routing::Features::RecurringTasks::Config
#active Karafka::Pro::Routing::Features::LongRunningJob::Config
#active Karafka::Pro::Routing::Features::AdaptiveIterator::Config
#active Karafka::Pro::Routing::Features::DirectAssignments::Config
#active Karafka::Pro::Routing::Features::ScheduledMessages::Config
#active Karafka::Pro::Routing::Features::VirtualPartitions::Config
#active Karafka::Routing::Features::ManualOffsetManagement::Config
#active? Karafka::Routing::Topic
#active? Karafka::Connection::Status
#active? Karafka::Connection::Listener
#active? Karafka::Routing::ConsumerGroup
#active? Karafka::Routing::ActivityManager
#active? Karafka::Routing::SubscriptionGroup
#active? Karafka::Connection::RebalanceManager
#active? Karafka::Pro::Routing::Features::Swarm::Topic
#active? Karafka::Pro::Routing::Features::Filtering::Config
#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
#active_within? Karafka::Pro::Processing::Coordinator
#adaptive_iterator Karafka::Pro::Routing::Features::AdaptiveIterator::Topic
#adaptive_iterator? Karafka::Pro::Routing::Features::AdaptiveIterator::Topic
#add Karafka::Processing::InlineInsights::Tracker
#after_call Karafka::Processing::Jobs::Base
#after_call Karafka::Processing::Jobs::Consume
#after_consume Karafka::Processing::Executor
aliases Karafka::Cli::Base
#alive? Karafka::Swarm::Node
#alive? Karafka::Swarm::Pidfd
#alive? Karafka::Helpers::Async
all Karafka::Admin::Acl
#all Karafka::Pro::Processing::Coordinators::ErrorsTracker
alter Karafka::Admin::Configs
#applied? Karafka::Pro::Processing::Filters::Base
#applied? Karafka::Pro::Processing::Coordinators::FiltersApplier
#apply! Karafka::Pro::Processing::Filters::Base
#apply! Karafka::Pro::Processing::Filters::Delayer
#apply! Karafka::Pro::Processing::Filters::Expirer
#apply! Karafka::Pro::Processing::Filters::Throttler
#apply! Karafka::Pro::Processing::Filters::VirtualLimiter
#apply! Karafka::Pro::Processing::Coordinators::FiltersApplier
#apply! Karafka::Pro::Processing::Filters::InlineInsightsDelayer
#apply_command Karafka::Pro::RecurringTasks::Executor
#apply_dlq_flow Karafka::Pro::Processing::Strategies::Dlq::Default
#assigned_partitions Karafka::Connection::RebalanceManager
#assignment Karafka::Connection::Client
#assignment_lost? Karafka::Connection::Client
assignments Karafka::App
#assignments Karafka::Routing::SubscriptionGroup
#assignments Karafka::Pro::Routing::Features::DirectAssignments::SubscriptionGroup
#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::Base
#before_call Karafka::Processing::Jobs::Consume
#before_consume Karafka::Processing::Executor
#before_schedule Karafka::Processing::Jobs::Base
#before_schedule Karafka::Processing::Jobs::Idle
#before_schedule Karafka::Processing::Jobs::Eofed
#before_schedule Karafka::Processing::Jobs::Consume
#before_schedule Karafka::Processing::Jobs::Revoked
#before_schedule Karafka::Processing::Jobs::Shutdown
#before_schedule Karafka::Pro::Processing::Jobs::Periodic
#before_schedule_consume Karafka::Processing::Executor
#before_schedule_eofed Karafka::Processing::Executor
#before_schedule_idle Karafka::Processing::Executor
#before_schedule_periodic Karafka::Pro::Processing::Executor
#before_schedule_revoked Karafka::Processing::Executor
#before_schedule_shutdown Karafka::Processing::Executor
#boot Karafka::Pro::Routing::Features::Multiplexing::Config
boot Karafka::Pro::Routing::Features::Multiplexing::Contracts::Topic
boot_file Karafka
#buffer Karafka::Pro::ScheduledMessages::Dispatcher
#build_dlq_message Karafka::Pro::Processing::Strategies::Dlq::Default
#cache Karafka::Pro::Routing::Features::OffsetMetadata::Config
#call Karafka::Runner
#call Karafka::Cli::Base
#call Karafka::Cli::Help
#call Karafka::Cli::Info
#call Karafka::Cli::Swarm
#call Karafka::Cli::Server
#call Karafka::Cli::Topics
#call Karafka::Cli::Console
#call Karafka::Cli::Install
#call Karafka::Cli::Topics::Plan
#call Karafka::Messages::Parser
#call Karafka::Cli::Topics::Align
#call Karafka::Cli::Topics::Reset
#call Karafka::Cli::Topics::Create
#call Karafka::Cli::Topics::Delete
#call Karafka::Deserializers::Key
#call Karafka::Cli::Topics::Migrate
#call Karafka::Connection::Listener
#call Karafka::Processing::Jobs::Base
#call Karafka::Processing::Jobs::Idle
#call Karafka::Deserializers::Headers
#call Karafka::Deserializers::Payload
#call Karafka::Pro::Iterator::Expander
#call Karafka::Processing::Jobs::Eofed
#call Karafka::Cli::Topics::Repartition
#call Karafka::Processing::Partitioner
#call Karafka::Helpers::IntervalRunner
#call Karafka::Processing::Jobs::Consume
#call Karafka::Processing::Jobs::Revoked
#call Karafka::Pro::Iterator::TplBuilder
#call Karafka::Pro::RecurringTasks::Task
#call Karafka::Processing::Jobs::Shutdown
call Karafka::Messages::Builders::Message
call Karafka::Messages::Builders::Messages
#call Karafka::Pro::Processing::Partitioner
#call Karafka::Pro::Processing::Jobs::Periodic
#call Karafka::Pro::RecurringTasks::Executor
#call Karafka::Pro::Encryption::Messages::Parser
#call Karafka::Instrumentation::Callbacks::Error
call Karafka::Messages::Builders::BatchMetadata
#call Karafka::Pro::RecurringTasks::Deserializer
#call Karafka::Pro::Encryption::Messages::Middleware
#call Karafka::Routing::SubscriptionGroupsBuilder
#call Karafka::Instrumentation::Callbacks::Statistics
call Karafka::Pro::ScheduledMessages::SchemaValidator
#call Karafka::Pro::ScheduledMessages::Deserializers::Headers
#call Karafka::Pro::ScheduledMessages::Deserializers::Payload
#call Karafka::Instrumentation::Callbacks::OauthbearerTokenRefresh
#call? Karafka::Pro::RecurringTasks::Task
#call_on_partitions_assign Karafka::Patches::Rdkafka::Opaque
#call_on_partitions_revoke Karafka::Patches::Rdkafka::Opaque
cancel Karafka::Pro::ScheduledMessages
cancel Karafka::Pro::ScheduledMessages::Proxy
#cause Karafka::Processing::Result
#changed? Karafka::Pro::RecurringTasks::Task
#changed? Karafka::Connection::RebalanceManager
#checkpoint Karafka::TimeTrackers::Poll
#clean! Karafka::Pro::Cleaner::Messages::Message
#clean_after_yielding Karafka::Pro::Routing::Features::AdaptiveIterator::Config
#cleaned? Karafka::Pro::Cleaner::Messages::Message
#cleanup Karafka::Swarm::Node
#cleanup Karafka::Swarm::Pidfd
#cleanup Karafka::Swarm::Manager
#clear Karafka::Process
#clear Karafka::Routing::Builder
#clear Karafka::Processing::JobsQueue
#clear Karafka::Pro::RecurringTasks::Task
#clear Karafka::Routing::ActivityManager
#clear Karafka::Pro::Processing::JobsQueue
#clear Karafka::Processing::ExecutorsBuffer
#clear Karafka::Connection::RebalanceManager
#clear Karafka::Connection::RawMessagesBuffer
#clear Karafka::Pro::Processing::Schedulers::Base
#clear Karafka::Processing::InlineInsights::Tracker
#clear Karafka::Instrumentation::AssignmentsTracker
#clear Karafka::Pro::Processing::OffsetMetadata::Fetcher
#clear Karafka::Pro::Processing::Coordinators::ErrorsTracker
#clear Karafka::Pro::Processing::Coordinators::VirtualOffsetManager
#client Karafka::BaseConsumer
#close Karafka::Processing::JobsQueue
#close Karafka::Processing::TimedQueue
cluster_info Karafka::Admin
#collapse_until! Karafka::Pro::Processing::Collapser
#collapse_until! Karafka::Pro::Processing::Strategies::Vp::Default
#collapsed? Karafka::Pro::Processing::Collapser
#collapsed? Karafka::Pro::Processing::Strategies::Vp::Default
command Karafka::Pro::RecurringTasks::Dispatcher
#command Karafka::Pro::RecurringTasks::Serializer
commands Karafka::Cli::Base
#commit_offsets Karafka::Connection::Proxy
#commit_offsets Karafka::Connection::Client
#commit_offsets Karafka::Processing::Strategies::Default
#commit_offsets! Karafka::Connection::Client
#commit_offsets! Karafka::Processing::Strategies::Default
#committed Karafka::Connection::Proxy
#committed Karafka::Connection::Client
#complete Karafka::Processing::JobsQueue
#config Karafka::Setup::Dsl
#config Karafka::Routing::Features::Declaratives::Topic
#config Karafka::Pro::Routing::Features::Patterns::Pattern
#configs Karafka::Admin::Configs::Resource
console Karafka::Cli::Console
#consume Karafka::ActiveJob::Consumer
#consume Karafka::Processing::Executor
#consume Karafka::Pro::ActiveJob::Consumer
#consume Karafka::Processing::JobsBuilder
#consume Karafka::Pro::Processing::JobsBuilder
#consume Karafka::Pro::RecurringTasks::Consumer
#consume Karafka::Pro::ScheduledMessages::Consumer
#consumer Karafka::Routing::Topic
consumer Karafka::Setup::AttributesMap
consumer Karafka::Setup::DefaultsInjector
#consumer_class Karafka::Routing::Topic
#consumer_group Karafka::Routing::Topic
#consumer_group Karafka::Routing::SubscriptionGroup
#consumer_group_id Karafka::Routing::SubscriptionGroup
#consumer_group_metadata_pointer Karafka::Connection::Client
consumer_groups Karafka::App
#consumption Karafka::Processing::Coordinator
#consumption_lag Karafka::Messages::BatchMetadata
#control Karafka::Swarm::Manager
#control Karafka::Connection::Manager
#control Karafka::Pro::Connection::Manager
#coordinator Karafka::BaseConsumer
#coordinator Karafka::Processing::Executor
core_root Karafka
#count Karafka::Instrumentation::Vendors::Appsignal::Client
#count Karafka::Instrumentation::Vendors::Appsignal::MetricsListener
create Karafka::Admin::Acl
create_partitions Karafka::Admin
create_topic Karafka::Admin
#created_at Karafka::Messages::BatchMetadata
#created_at Karafka::Pro::ScheduledMessages::Day
#cron Karafka::Pro::RecurringTasks::Task
#current Karafka::Instrumentation::AssignmentsTracker
#current_subscription_group_details Karafka::Routing::ConsumerGroup
#current_timeout Karafka::TimeTrackers::Pause
#cursor Karafka::Pro::Processing::Filters::Base
#cursor Karafka::Pro::Processing::Coordinators::FiltersApplier
#daily Karafka::Pro::ScheduledMessages::Tracker
#dead_letter_queue Karafka::Routing::Features::DeadLetterQueue::Topic
#dead_letter_queue Karafka::Pro::Routing::Features::DeadLetterQueue::Topic
#dead_letter_queue? Karafka::Routing::Features::DeadLetterQueue::Topic
debug! Karafka::App
#declaratives Karafka::Routing::Features::Declaratives::Topic
#declaratives? Karafka::Routing::Features::Declaratives::Topic
#decrement Karafka::Processing::Coordinator
#decrypt Karafka::Pro::Encryption::Cipher
#default? Karafka::Admin::Configs::Config
#defaults Karafka::Routing::Builder
define Karafka::Pro::RecurringTasks
#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::Admin::Acl
#delete Karafka::Connection::RawMessagesBuffer
#delete Karafka::Pro::ScheduledMessages::DailyBuffer
delete_consumer_group Karafka::Admin
#delete_if Karafka::Routing::Topics
delete_topic Karafka::Admin
desc Karafka::Cli::Base
describe Karafka::Admin::Acl
describe Karafka::Admin::Configs
#deserialize! Karafka::Messages::Messages
#deserialized? Karafka::Messages::Message
#deserializer Karafka::Routing::Features::Deserializers::Topic
#deserializer Karafka::Pro::Routing::Features::OffsetMetadata::Config
#deserializers Karafka::Messages::Metadata
#deserializers Karafka::Messages::BatchMetadata
#deserializers Karafka::Routing::Features::Deserializers::Topic
#deserializers? Karafka::Routing::Features::Deserializers::Topic
#details Karafka::Routing::Features::Declaratives::Config
detect Karafka::Licenser
#direct_assignments Karafka::Pro::Routing::Features::DirectAssignments::Topic
#disable Karafka::Pro::RecurringTasks::Task
#discovered? Karafka::Pro::Routing::Features::Patterns::Config
#dispatch Karafka::ActiveJob::Dispatcher
#dispatch Karafka::Pro::ActiveJob::Dispatcher
#dispatch_at Karafka::ActiveJob::Dispatcher
#dispatch_at Karafka::Pro::ActiveJob::Dispatcher
#dispatch_if_needed_and_mark_as_consumed Karafka::Pro::Processing::Strategies::Dlq::Default
#dispatch_in_a_transaction? Karafka::Pro::Processing::Strategies::Dlq::Default
#dispatch_many Karafka::ActiveJob::Dispatcher
#dispatch_many Karafka::Pro::ActiveJob::Dispatcher
#dispatch_method Karafka::Routing::Features::DeadLetterQueue::Config
#dispatch_to_dlq Karafka::Processing::Strategies::Dlq
#dispatch_to_dlq Karafka::Pro::Processing::Strategies::Dlq::Default
#dispatch_to_dlq? Karafka::Pro::Processing::Strategies::Dlq::Default
done? Karafka::App
#done? Karafka::Status
#done? Karafka::Connection::Manager
#draw Karafka::Routing::Builder
#during_pause Karafka::Pro::Routing::Features::PeriodicJob::Config
#during_retry Karafka::Pro::Routing::Features::PeriodicJob::Config
#dynamic? Karafka::Pro::Routing::Features::Multiplexing::Config
#each Karafka::Pro::Iterator
#each Karafka::Routing::Topics
#each Karafka::Messages::Messages
#each Karafka::Processing::WorkersBatch
#each Karafka::Connection::ListenersBatch
#each Karafka::Connection::MessagesBuffer
#each Karafka::Processing::ExecutorsBuffer
#each Karafka::Pro::RecurringTasks::Schedule
#each Karafka::Pro::Cleaner::Messages::Messages
#each Karafka::Connection::RawMessagesBuffer
#each Karafka::Pro::Processing::AdaptiveIterator::Consumer
#each Karafka::Pro::Processing::Coordinators::ErrorsTracker
#empty? Karafka::Messages::Messages
#empty? Karafka::Processing::JobsQueue
#empty? Karafka::Pro::Processing::JobsQueue
#empty? Karafka::Connection::MessagesBuffer
#empty? Karafka::Pro::Processing::Coordinators::ErrorsTracker
#enable Karafka::Pro::RecurringTasks::Task
#enabled? Karafka::Pro::RecurringTasks::Task
#encrypt Karafka::Pro::Encryption::Cipher
#ended? Karafka::Pro::ScheduledMessages::Day
#ends_at Karafka::Pro::ScheduledMessages::Day
#enough? Karafka::Pro::Processing::AdaptiveIterator::Tracker
#enqueue ActiveJob::QueueAdapters::KarafkaAdapter
#enqueue_after_transaction_commit? ActiveJob::QueueAdapters::KarafkaAdapter
#enqueue_all ActiveJob::QueueAdapters::KarafkaAdapter
#enqueue_at ActiveJob::QueueAdapters::KarafkaAdapter
#ensure_fugit_availability! Karafka::Pro::Routing::Features::RecurringTasks::Builder
ensure_supported! Karafka::Swarm
env Karafka
env= Karafka
#eof Karafka::Connection::RawMessagesBuffer
#eofed Karafka::Processing::Executor
#eofed Karafka::Processing::Coordinator
#eofed Karafka::Processing::JobsBuilder
#eofed Karafka::Pro::Processing::JobsBuilder
#eofed Karafka::Pro::RecurringTasks::Consumer
#eofed Karafka::Routing::Features::Eofed::Topic
#eofed Karafka::Pro::ScheduledMessages::Consumer
#eofed? Karafka::Processing::Coordinator
#eofed? Karafka::Routing::Features::Eofed::Topic
#errors_tracker Karafka::Pro::BaseConsumer
#errors_tracker Karafka::Pro::Processing::Coordinator
#events_poll Karafka::Connection::Client
#exceeded? Karafka::TimeTrackers::Poll
#exclude Karafka::Routing::ActivityManager
#execute Karafka::Pro::RecurringTasks::Task
execution_mode Karafka::Server
#executor Karafka::Processing::Jobs::Base
#expand Karafka::Pro::Routing::Features::Patterns::Detector
#expand Karafka::Pro::Routing::Features::Multiplexing::SubscriptionGroupsBuilder
#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::Helpers::ConfigImporter
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::Routing::Features::Filtering::Config
#filters Karafka::Pro::Processing::Coordinators::FiltersApplier
#find Karafka::Routing::Topics
#find Karafka::Pro::RecurringTasks::Schedule
#find Karafka::Processing::StrategySelector
#find Karafka::Processing::ExpansionsSelector
#find Karafka::Pro::Processing::StrategySelector
#find Karafka::Pro::Processing::ExpansionsSelector
#find Karafka::Processing::InlineInsights::Tracker
#find Karafka::Pro::Routing::Features::Patterns::Topics
#find Karafka::Pro::Processing::OffsetMetadata::Fetcher
#find Karafka::Pro::Routing::Features::Patterns::Patterns
#find_all Karafka::Processing::ExecutorsBuffer
#find_all_or_create Karafka::Processing::ExecutorsBuffer
find_by Karafka::Routing::Router
#find_or_create Karafka::Processing::ExecutorsBuffer
#find_or_create Karafka::Processing::CoordinatorsBuffer
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! Karafka::Processing::Jobs::Base
#finished? Karafka::Processing::Jobs::Base
#finished? Karafka::Pro::Processing::Coordinator
#first Karafka::Messages::Messages
#first_offset Karafka::Messages::BatchMetadata
#flush Karafka::Pro::ScheduledMessages::Dispatcher
#for_dispatch Karafka::Pro::ScheduledMessages::DailyBuffer
#fresh? Karafka::Pro::ScheduledMessages::State
from_rd_kafka Karafka::Admin::Configs::Config
#gauge Karafka::Instrumentation::Vendors::Appsignal::Client
#gauge Karafka::Instrumentation::Vendors::Appsignal::MetricsListener
gem_root Karafka
generate Karafka::Setup::AttributesMap
#green Karafka::Helpers::Colorize
#grey Karafka::Helpers::Colorize
#group_id Karafka::Processing::Executor
#groups Karafka::Pro::Processing::Coordinators::VirtualOffsetManager
#handle_after_consume Karafka::Processing::Strategies::Dlq
#handle_after_consume Karafka::Processing::Strategies::Mom
#handle_after_consume Karafka::Processing::Strategies::Base
#handle_after_consume Karafka::Processing::Strategies::Default
#handle_after_consume Karafka::Processing::Strategies::DlqMom
#handle_after_consume Karafka::Processing::Strategies::AjDlqMom
#handle_after_consume Karafka::Pro::Processing::Strategies::Default
#handle_after_consume Karafka::Pro::Processing::Strategies::Dlq::Ftr
#handle_after_consume Karafka::Pro::Processing::Strategies::Dlq::Lrj
#handle_after_consume Karafka::Pro::Processing::Strategies::Dlq::Mom
#handle_after_consume Karafka::Pro::Processing::Strategies::Lrj::Ftr
#handle_after_consume Karafka::Pro::Processing::Strategies::Lrj::Mom
#handle_after_consume Karafka::Pro::Processing::Strategies::Mom::Ftr
#handle_after_consume Karafka::Pro::Processing::Strategies::Aj::MomVp
#handle_after_consume Karafka::Pro::Processing::Strategies::Aj::DlqMom
#handle_after_consume Karafka::Pro::Processing::Strategies::Dlq::Default
#handle_after_consume Karafka::Pro::Processing::Strategies::Dlq::FtrLrj
#handle_after_consume Karafka::Pro::Processing::Strategies::Dlq::FtrMom
#handle_after_consume Karafka::Pro::Processing::Strategies::Dlq::LrjMom
#handle_after_consume Karafka::Pro::Processing::Strategies::Ftr::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::Pro::Processing::Strategies::Aj::DlqMomVp
#handle_after_consume Karafka::Pro::Processing::Strategies::Aj::FtrMomVp
#handle_after_consume Karafka::Pro::Processing::Strategies::Aj::LrjMomVp
#handle_after_consume Karafka::Pro::Processing::Strategies::Aj::DlqFtrMom
#handle_after_consume Karafka::Pro::Processing::Strategies::Aj::DlqLrjMom
#handle_after_consume Karafka::Pro::Processing::Strategies::Dlq::FtrLrjMom
#handle_after_consume Karafka::Pro::Processing::Strategies::Aj::DlqFtrMomVp
#handle_after_consume Karafka::Pro::Processing::Strategies::Aj::DlqLrjMomVp
#handle_after_consume Karafka::Pro::Processing::Strategies::Aj::FtrLrjMomVp
#handle_after_consume Karafka::Pro::Processing::Strategies::Aj::DlqFtrLrjMom
#handle_after_consume Karafka::Pro::Processing::Strategies::Aj::DlqFtrLrjMomVp
#handle_before_consume Karafka::Processing::Strategies::Base
#handle_before_consume Karafka::Processing::Strategies::Default
#handle_before_consume Karafka::Pro::Processing::Strategies::Default
#handle_before_schedule_consume Karafka::Pro::Processing::Strategies::Default
#handle_before_schedule_consume Karafka::Pro::Processing::Strategies::Lrj::Mom
#handle_before_schedule_consume Karafka::Pro::Processing::Strategies::Lrj::Default
#handle_before_schedule_consume Karafka::Pro::Processing::Strategies::Aj::LrjMomVp
#handle_before_schedule_tick Karafka::Pro::Processing::Strategies::Default
#handle_consume Karafka::Processing::Strategies::Base
#handle_consume Karafka::Processing::Strategies::Default
#handle_consume Karafka::Pro::Processing::Strategies::Default
#handle_eofed Karafka::Processing::Strategies::Default
#handle_idle Karafka::Processing::Strategies::Base
#handle_idle Karafka::Processing::Strategies::Default
#handle_idle Karafka::Pro::Processing::Strategies::Ftr::Default
#handle_initialized Karafka::Processing::Strategies::Default
#handle_post_filtering Karafka::Pro::Processing::Strategies::Ftr::Default
#handle_revoked Karafka::Processing::Strategies::Base
#handle_revoked Karafka::Processing::Strategies::Default
#handle_revoked Karafka::Pro::Processing::Strategies::Default
#handle_revoked Karafka::Pro::Processing::Strategies::Lrj::Mom
#handle_revoked Karafka::Pro::Processing::Strategies::Lrj::Default
#handle_revoked Karafka::Pro::Processing::Strategies::Aj::LrjMomVp
#handle_shutdown Karafka::Processing::Strategies::Base
#handle_shutdown Karafka::Processing::Strategies::Default
#handle_tick Karafka::Pro::Processing::Strategies::Default
#headers Karafka::Messages::Metadata
#headers Karafka::Routing::Features::Deserializers::Config
#healthy Karafka::Swarm::Node
#healthy? Karafka::Instrumentation::Vendors::Kubernetes::BaseListener
#healthy? Karafka::Instrumentation::Vendors::Kubernetes::LivenessListener
#host Karafka::Admin::Acl
#id Karafka::Swarm::Node
#id Karafka::BaseConsumer
#id Karafka::Routing::Topic
#id Karafka::Connection::Client
#id Karafka::Processing::Worker
#id Karafka::Connection::Listener
#id Karafka::Processing::Executor
#id Karafka::Routing::ConsumerGroup
#id Karafka::Pro::RecurringTasks::Task
#id Karafka::Routing::SubscriptionGroup
id Karafka::Routing::SubscriptionGroup
#idle Karafka::Processing::Executor
#idle Karafka::Pro::Processing::JobsBuilder
#in_processing Karafka::Pro::Processing::JobsQueue
#include Karafka::Routing::ActivityManager
included Karafka::Helpers::Async
#included Karafka::Helpers::ConfigImporter
included Karafka::Pro::Processing::PeriodicJob::Consumer
#incompatible? Karafka::Pro::RecurringTasks::Executor
#increment Karafka::TimeTrackers::Pause
#increment Karafka::Processing::Coordinator
#independent Karafka::Routing::Features::DeadLetterQueue::Config
#initialize Karafka::Env
#initialize Karafka::Status
#initialize Karafka::Process
#initialize Karafka::Cli::Base
#initialize Karafka::Admin::Acl
#initialize Karafka::Swarm::Node
#initialize Karafka::Cli::Install
#initialize Karafka::Swarm::Pidfd
#initialize Karafka::Pro::Iterator
#initialize Karafka::BaseConsumer
#initialize Karafka::Routing::Proxy
#initialize Karafka::Routing::Topic
#initialize Karafka::Swarm::Manager
#initialize Karafka::Routing::Topics
#initialize Karafka::Routing::Builder
#initialize Karafka::Connection::Proxy
#initialize Karafka::Messages::Message
#initialize Karafka::Swarm::Supervisor
#initialize Karafka::Connection::Client
#initialize Karafka::Connection::Status
#initialize Karafka::Messages::Messages
#initialize Karafka::Processing::Result
#initialize Karafka::Processing::Worker
#initialize Karafka::Connection::Manager
#initialize Karafka::TimeTrackers::Poll
#initialize Karafka::Connection::Listener
#initialize Karafka::Processing::Executor
#initialize Karafka::TimeTrackers::Pause
#initialize Karafka::Admin::Configs::Config
#initialize Karafka::Connection::Conductor
#initialize Karafka::Processing::Jobs::Base
#initialize Karafka::Processing::Jobs::Idle
#initialize Karafka::Pro::Encryption::Cipher
#initialize Karafka::Processing::Jobs::Eofed
#initialize Karafka::Processing::JobsQueue
#initialize Karafka::Admin::Configs::Resource
#initialize Karafka::Instrumentation::Logger
#initialize Karafka::Pro::Connection::Manager
#initialize Karafka::Processing::Coordinator
#initialize Karafka::Processing::Partitioner
#initialize Karafka::Processing::TimedQueue
#initialize Karafka::Routing::ConsumerGroup
#initialize Karafka::Helpers::ConfigImporter
#initialize Karafka::Helpers::IntervalRunner
#initialize Karafka::Helpers::MultiDelegator
#initialize Karafka::Instrumentation::Monitor
#initialize Karafka::Processing::Jobs::Consume
#initialize Karafka::Processing::Jobs::Revoked
#initialize Karafka::Swarm::LivenessListener
#initialize Karafka::Pro::Iterator::TplBuilder
#initialize Karafka::Pro::Processing::Collapser
#initialize Karafka::Pro::RecurringTasks::Task
#initialize Karafka::Processing::Jobs::Shutdown
#initialize Karafka::Processing::WorkersBatch
#initialize Karafka::Routing::ActivityManager
#initialize Karafka::Connection::PausesManager
#initialize Karafka::Pro::Processing::JobsQueue
#initialize Karafka::Connection::ListenersBatch
#initialize Karafka::Connection::MessagesBuffer
#initialize Karafka::Pro::Processing::Coordinator
#initialize Karafka::Pro::ScheduledMessages::Day
#initialize Karafka::Routing::SubscriptionGroup
#initialize Karafka::Pro::Processing::Filters::Base
#initialize Karafka::Pro::Swarm::LivenessListener
#initialize Karafka::Processing::ExecutorsBuffer
#initialize Karafka::Connection::RebalanceManager
#initialize Karafka::Pro::Processing::Jobs::Periodic
#initialize Karafka::Pro::RecurringTasks::Consumer
#initialize Karafka::Pro::RecurringTasks::Executor
#initialize Karafka::Pro::RecurringTasks::Schedule
#initialize Karafka::Pro::ScheduledMessages::State
#initialize Karafka::Processing::StrategySelector
#initialize Karafka::Instrumentation::Notifications
#initialize Karafka::Processing::Schedulers::Default
#initialize Karafka::Connection::RawMessagesBuffer
#initialize Karafka::Pro::Processing::Filters::Delayer
#initialize Karafka::Pro::Processing::Filters::Expirer
#initialize Karafka::Pro::Processing::Schedulers::Base
#initialize Karafka::Pro::ScheduledMessages::Tracker
#initialize Karafka::Processing::CoordinatorsBuffer
#initialize Karafka::Routing::Features::Base::Expander
#initialize Karafka::Instrumentation::Callbacks::Error
#initialize Karafka::Instrumentation::LoggerListener
#initialize Karafka::Pro::Processing::Filters::Throttler
#initialize Karafka::Pro::Processing::StrategySelector
#initialize Karafka::Pro::ScheduledMessages::MaxEpoch
#initialize Karafka::Pro::ScheduledMessages::Dispatcher
#initialize Karafka::Processing::InlineInsights::Tracker
#initialize Karafka::Instrumentation::AssignmentsTracker
#initialize Karafka::Instrumentation::Callbacks::Rebalance
#initialize Karafka::Pro::ScheduledMessages::DailyBuffer
#initialize Karafka::Routing::SubscriptionGroupsBuilder
#initialize Karafka::Instrumentation::Callbacks::Statistics
#initialize Karafka::Pro::Connection::Multiplexing::Listener
#initialize Karafka::Pro::Routing::Features::Patterns::Pattern
#initialize Karafka::Instrumentation::Vendors::Appsignal::Base
#initialize Karafka::Pro::Processing::Filters::VirtualLimiter
#initialize Karafka::Pro::Processing::Jobs::EofedNonBlocking
#initialize Karafka::Pro::Processing::OffsetMetadata::Fetcher
#initialize Karafka::Pro::Instrumentation::PerformanceTracker
#initialize Karafka::Instrumentation::Vendors::Appsignal::Client
#initialize Karafka::Pro::Processing::AdaptiveIterator::Tracker
#initialize Karafka::Pro::Processing::Jobs::ConsumeNonBlocking
#initialize Karafka::Pro::Processing::Jobs::RevokedNonBlocking
#initialize Karafka::Pro::Processing::Jobs::PeriodicNonBlocking
#initialize Karafka::Pro::Processing::Coordinators::ErrorsTracker
#initialize Karafka::Pro::Processing::Coordinators::FiltersApplier
#initialize Karafka::Pro::Routing::Features::Patterns::ConsumerGroup
#initialize Karafka::Pro::Processing::Filters::InlineInsightsDelayer
#initialize Karafka::Instrumentation::Vendors::Datadog::LoggerListener
#initialize Karafka::Instrumentation::Vendors::Datadog::MetricsListener
#initialize Karafka::Instrumentation::Vendors::Kubernetes::BaseListener
#initialize Karafka::Pro::Processing::Coordinators::VirtualOffsetManager
#initialize Karafka::Instrumentation::Callbacks::OauthbearerTokenRefresh
#initialize Karafka::Instrumentation::Vendors::Kubernetes::LivenessListener
#initialize Karafka::Instrumentation::Vendors::Kubernetes::SwarmLivenessListener
#initialized Karafka::Pro::ScheduledMessages::Consumer
#inline_insights Karafka::Routing::Features::InlineInsights::Topic
#inline_insights Karafka::Pro::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
#interval Karafka::Pro::Routing::Features::PeriodicJob::Config
jobs_queue Karafka::Server
#kafka Karafka::Routing::SubscriptionGroup
#kafka= Karafka::Routing::Topic
#karafka_options Karafka::ActiveJob::JobExtensions
#key Karafka::Messages::Metadata
#key Karafka::Routing::Features::Deserializers::Config
#key_location Karafka::Instrumentation::Vendors::Datadog::MetricsListener::RdKafkaMetric
#key_location Karafka::Instrumentation::Vendors::Appsignal::MetricsListener::RdKafkaMetric
#lag Karafka::Connection::Proxy
#last Karafka::Messages::Messages
#last Karafka::Pro::Processing::Coordinators::ErrorsTracker
#last_offset Karafka::Messages::BatchMetadata
#last_polled_at Karafka::Processing::Coordinator
#last_polled_at Karafka::Connection::RawMessagesBuffer
#limit Karafka::Pro::Routing::Features::Throttling::Config
listeners Karafka::Server
load Karafka::Cli::Base
load_all Karafka::Routing::Features::Base
#loaded! Karafka::Pro::ScheduledMessages::State
#loaded? Karafka::Pro::ScheduledMessages::State
#lock Karafka::Pro::Processing::JobsQueue
#lock_async Karafka::Pro::Processing::JobsQueue
log Karafka::Pro::RecurringTasks::Dispatcher
#log Karafka::Pro::RecurringTasks::Serializer
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
#manage Karafka::Pro::Processing::Schedulers::Base
#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::Coordinators::VirtualOffsetManager
#mark_after_dispatch Karafka::Routing::Features::DeadLetterQueue::Config
#mark_after_dispatch? Karafka::Processing::Strategies::Dlq
#mark_after_dispatch? Karafka::Processing::Strategies::DlqMom
#mark_after_dispatch? Karafka::Pro::Processing::Strategies::Dlq::Mom
#mark_after_dispatch? Karafka::Pro::Processing::Strategies::Dlq::Default
#mark_after_dispatch? Karafka::Pro::Processing::Strategies::Dlq::FtrMom
#mark_after_dispatch? Karafka::Pro::Processing::Strategies::Dlq::LrjMom
#mark_as_consumed Karafka::Pro::Iterator
#mark_as_consumed Karafka::Connection::Client
#mark_as_consumed Karafka::Processing::Strategies::Dlq
#mark_as_consumed Karafka::Processing::Strategies::Default
#mark_as_consumed Karafka::Pro::Processing::Strategies::Default
#mark_as_consumed Karafka::Pro::Processing::Strategies::Vp::Default
#mark_as_consumed Karafka::Pro::Processing::Strategies::Dlq::Default
#mark_as_consumed! Karafka::Pro::Iterator
#mark_as_consumed! Karafka::Connection::Client
#mark_as_consumed! Karafka::Processing::Strategies::Dlq
#mark_as_consumed! Karafka::Processing::Strategies::Default
#mark_as_consumed! Karafka::Pro::Processing::Strategies::Default
#mark_as_consumed! Karafka::Pro::Processing::Strategies::Vp::Default
#mark_as_consumed! Karafka::Pro::Processing::Strategies::Dlq::Default
#mark_as_consumed? Karafka::Pro::Processing::Filters::Base
#mark_as_consumed? Karafka::Pro::Processing::Coordinators::FiltersApplier
#mark_dispatched_to_dlq Karafka::Processing::Strategies::Dlq
#mark_dispatched_to_dlq Karafka::Pro::Processing::Strategies::Dlq::Default
#mark_in_transaction Karafka::Pro::Processing::Strategies::Default
#mark_in_transaction Karafka::Pro::Processing::Strategies::Vp::Default
#mark_until Karafka::Pro::Processing::Coordinators::VirtualOffsetManager
#markable Karafka::Pro::Processing::Coordinators::VirtualOffsetManager
#markable? Karafka::Pro::Processing::Coordinators::VirtualOffsetManager
#marked Karafka::Pro::Processing::Coordinators::VirtualOffsetManager
#marked? Karafka::Processing::Coordinator
#marking_method Karafka::Pro::Processing::Filters::Base
#marking_method Karafka::Routing::Features::DeadLetterQueue::Config
#marking_method Karafka::Pro::Processing::Coordinators::FiltersApplier
#marking_method Karafka::Pro::Routing::Features::AdaptiveIterator::Config
#matcher? Karafka::Pro::Routing::Features::Patterns::Config
#matches? Karafka::Pro::RecurringTasks::Matcher
#materialized Karafka::Pro::Routing::Features::PeriodicJob::Config
#max Karafka::Pro::Routing::Features::Multiplexing::Config
max Karafka::Pro::Routing::Features::Multiplexing::Contracts::Topic
#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
#message Karafka::Messages::Metadata
#messages Karafka::BaseConsumer
#messages Karafka::Processing::Executor
#messages Karafka::Processing::Jobs::Consume
#metadata Karafka::Connection::Proxy
#metadata Karafka::Messages::Message
#metadata Karafka::Messages::Messages
#metadata= Karafka::Instrumentation::Vendors::Appsignal::Client
#method_missing Karafka::Env
#method_missing Karafka::Routing::Proxy
#min Karafka::Pro::Routing::Features::Multiplexing::Config
min Karafka::Pro::Routing::Features::Multiplexing::Contracts::Topic
monitor Karafka
#multiplexing Karafka::Pro::Routing::Features::Multiplexing::Proxy
#multiplexing Karafka::Pro::Routing::Features::Multiplexing::SubscriptionGroup
#multiplexing? Karafka::Pro::Routing::Features::Multiplexing::SubscriptionGroup
name Karafka::Cli::Base
#name Karafka::Routing::Topic
#name Karafka::Connection::Client
#name Karafka::Admin::Configs::Config
#name Karafka::Admin::Configs::Resource
#name Karafka::Routing::ConsumerGroup
#name Karafka::Routing::SubscriptionGroup
#name Karafka::Pro::Routing::Features::Patterns::Pattern
#name Karafka::Instrumentation::Vendors::Datadog::MetricsListener::RdKafkaMetric
#name Karafka::Instrumentation::Vendors::Appsignal::MetricsListener::RdKafkaMetric
names Karafka::Cli::Base
#next_time Karafka::Pro::RecurringTasks::Task
#nodes Karafka::Swarm::Manager
#nodes Karafka::Pro::Routing::Features::Swarm::Config
#non_blocking? Karafka::Processing::Jobs::Base
#non_blocking_job Karafka::Pro::Routing::Features::NonBlockingJob::Topic
#notice Karafka::Pro::Connection::Manager
#notifications_bus Karafka::Instrumentation::Monitor
#offset Karafka::Messages::Seek
#offset Karafka::Messages::Metadata
#offset_metadata Karafka::Pro::Processing::OffsetMetadata::Consumer
#offset_metadata Karafka::Pro::Routing::Features::OffsetMetadata::Topic
#offset_metadata? Karafka::Pro::Routing::Features::OffsetMetadata::Topic
#offset_metadata_strategy Karafka::Pro::Routing::Features::VirtualPartitions::Config
#offsets_for_times Karafka::Connection::Proxy
#on_after_consume Karafka::BaseConsumer
#on_any_active Karafka::Process
#on_app_quiet Karafka::Instrumentation::LoggerListener
#on_app_quieting Karafka::Instrumentation::LoggerListener
#on_app_running Karafka::Instrumentation::LoggerListener
#on_app_running Karafka::Instrumentation::Vendors::Appsignal::MetricsListener
#on_app_running Karafka::Instrumentation::Vendors::Kubernetes::LivenessListener
#on_app_stopped Karafka::Instrumentation::LoggerListener
#on_app_stopped Karafka::Instrumentation::Vendors::Kubernetes::LivenessListener
#on_app_stopping Karafka::Instrumentation::LoggerListener
#on_app_supervising Karafka::Instrumentation::Vendors::Kubernetes::SwarmLivenessListener
#on_before_consume Karafka::BaseConsumer
#on_before_schedule_consume Karafka::BaseConsumer
#on_before_schedule_eofed Karafka::BaseConsumer
#on_before_schedule_idle Karafka::BaseConsumer
#on_before_schedule_revoked Karafka::BaseConsumer
#on_before_schedule_shutdown Karafka::BaseConsumer
#on_before_schedule_tick Karafka::Pro::Processing::PeriodicJob::Consumer
#on_clear Karafka::Processing::Schedulers::Default
#on_clear Karafka::Pro::Processing::Schedulers::Base
#on_clear Karafka::Pro::Processing::Schedulers::Default
#on_client_pause Karafka::Instrumentation::LoggerListener
#on_client_reset Karafka::Instrumentation::AssignmentsTracker
#on_client_resume Karafka::Instrumentation::LoggerListener
#on_connection_listener_before_fetch_loop Karafka::Pro::Processing::OffsetMetadata::Listener
#on_connection_listener_fetch_loop Karafka::Pro::Swarm::LivenessListener
#on_connection_listener_fetch_loop Karafka::Instrumentation::LoggerListener
#on_connection_listener_fetch_loop Karafka::Instrumentation::Vendors::Kubernetes::LivenessListener
#on_connection_listener_fetch_loop_received Karafka::Instrumentation::LoggerListener
#on_connection_listener_fetch_loop_received Karafka::Instrumentation::Vendors::Datadog::MetricsListener
#on_connection_listener_stopped Karafka::Pro::Swarm::LivenessListener
#on_connection_listener_stopped Karafka::Instrumentation::Vendors::Kubernetes::LivenessListener
#on_connection_listener_stopping Karafka::Pro::Swarm::LivenessListener
#on_connection_listener_stopping Karafka::Instrumentation::Vendors::Kubernetes::LivenessListener
#on_consume Karafka::BaseConsumer
#on_consumer_consume Karafka::Instrumentation::Vendors::Appsignal::MetricsListener
#on_consumer_consumed Karafka::Pro::Instrumentation::PerformanceTracker
#on_consumer_consumed Karafka::Instrumentation::Vendors::Datadog::MetricsListener
#on_consumer_consumed Karafka::Instrumentation::Vendors::Appsignal::MetricsListener
#on_consumer_consuming_retry Karafka::Instrumentation::LoggerListener
#on_consumer_consuming_seek Karafka::Instrumentation::LoggerListener
on_cooperative_rebalance Karafka::Patches::Rdkafka::Bindings
#on_dead_letter_queue_dispatched Karafka::Instrumentation::LoggerListener
#on_dead_letter_queue_dispatched Karafka::Instrumentation::Vendors::Appsignal::MetricsListener
on_eager_rebalance Karafka::Patches::Rdkafka::Bindings
#on_enqueued Karafka::Pro::Processing::Coordinator
#on_eofed Karafka::BaseConsumer
#on_error_occurred Karafka::Pro::Swarm::LivenessListener
#on_error_occurred Karafka::Pro::RecurringTasks::Listener
#on_error_occurred Karafka::Instrumentation::LoggerListener
#on_error_occurred Karafka::Instrumentation::Vendors::Datadog::LoggerListener
#on_error_occurred Karafka::Instrumentation::Vendors::Datadog::MetricsListener
#on_error_occurred Karafka::Instrumentation::Vendors::Appsignal::ErrorsListener
#on_error_occurred Karafka::Instrumentation::Vendors::Appsignal::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_initialized Karafka::BaseConsumer
#on_manage Karafka::Processing::Schedulers::Default
#on_manage Karafka::Pro::Processing::Schedulers::Base
#on_manage Karafka::Pro::Processing::Schedulers::Default
#on_partitions_assign Karafka::Instrumentation::Callbacks::Rebalance
#on_partitions_assigned Karafka::Instrumentation::Callbacks::Rebalance
#on_partitions_revoke Karafka::Instrumentation::Callbacks::Rebalance
#on_partitions_revoked Karafka::Instrumentation::Callbacks::Rebalance
#on_process_notice_signal Karafka::Instrumentation::LoggerListener
#on_rebalance_partitions_assigned Karafka::Connection::RebalanceManager
#on_rebalance_partitions_assigned Karafka::Instrumentation::AssignmentsTracker
#on_rebalance_partitions_assigned Karafka::Pro::Processing::OffsetMetadata::Listener
#on_rebalance_partitions_revoked Karafka::Connection::RebalanceManager
#on_rebalance_partitions_revoked Karafka::Instrumentation::AssignmentsTracker
#on_rebalance_partitions_revoked Karafka::Pro::Processing::OffsetMetadata::Listener
#on_recurring_tasks_task_executed Karafka::Pro::RecurringTasks::Listener
#on_revoked Karafka::BaseConsumer
#on_revoked Karafka::Pro::Processing::Coordinator
#on_schedule_consumption Karafka::Processing::Schedulers::Default
#on_schedule_consumption Karafka::Pro::Processing::Schedulers::Base
#on_schedule_consumption Karafka::Pro::Processing::Schedulers::Default
#on_schedule_idle Karafka::Pro::Processing::Schedulers::Base
#on_schedule_periodic Karafka::Pro::Processing::Schedulers::Base
#on_schedule_revocation Karafka::Pro::Processing::Schedulers::Base
#on_schedule_shutdown Karafka::Pro::Processing::Schedulers::Base
#on_shutdown Karafka::BaseConsumer
#on_started Karafka::Pro::Processing::Coordinator
#on_statistics_emitted Karafka::Swarm::LivenessListener
#on_statistics_emitted Karafka::Pro::Swarm::LivenessListener
#on_statistics_emitted Karafka::Processing::InlineInsights::Listener
#on_statistics_emitted Karafka::Pro::Connection::Multiplexing::Listener
#on_statistics_emitted Karafka::Instrumentation::Vendors::Datadog::MetricsListener
#on_statistics_emitted Karafka::Instrumentation::Vendors::Appsignal::MetricsListener
#on_swarm_manager_before_fork Karafka::Instrumentation::LoggerListener
#on_swarm_manager_control Karafka::Instrumentation::LoggerListener
#on_swarm_manager_control Karafka::Instrumentation::Vendors::Kubernetes::SwarmLivenessListener
#on_swarm_manager_stopping Karafka::Instrumentation::LoggerListener
#on_swarm_manager_terminating Karafka::Instrumentation::LoggerListener
#on_swarm_node_after_fork Karafka::Instrumentation::LoggerListener
#on_tick Karafka::Pro::Processing::PeriodicJob::Consumer
#on_worker_process Karafka::Instrumentation::LoggerListener
#on_worker_process Karafka::Instrumentation::Vendors::Datadog::LoggerListener
#on_worker_process Karafka::Instrumentation::Vendors::Datadog::MetricsListener
#on_worker_processed Karafka::Instrumentation::LoggerListener
#on_worker_processed Karafka::Instrumentation::Vendors::Datadog::LoggerListener
#on_worker_processed Karafka::Instrumentation::Vendors::Datadog::MetricsListener
#operation Karafka::Admin::Acl
option Karafka::Cli::Base
#options Karafka::Cli::Base
#orphaned? Karafka::Swarm::Node
parse_options Karafka::Cli::Base
#partition Karafka::Messages::Seek
#partition Karafka::Messages::Metadata
#partition Karafka::Processing::Coordinator
#partition Karafka::Messages::BatchMetadata
#partitioner Karafka::Pro::Routing::Features::VirtualPartitions::Config
#partitions Karafka::Routing::Features::Declaratives::Config
#partitions Karafka::Pro::Routing::Features::DirectAssignments::Config
#pattern Karafka::Pro::Routing::Features::Patterns::Config
#pattern Karafka::Pro::Routing::Features::Patterns::Builder
#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::Connection::Client
#pause Karafka::TimeTrackers::Pause
#pause Karafka::Pro::Routing::Features::Pausing::Topic
#pause Karafka::Pro::Processing::SubscriptionGroupsCoordinator
#pause_tracker Karafka::Processing::Coordinator
#paused? Karafka::TimeTrackers::Pause
#payload Karafka::Messages::Message
#payload Karafka::Pro::Cleaner::Messages::Message
#payload Karafka::Routing::Features::Deserializers::Config
#payloads Karafka::Messages::Messages
#periodic Karafka::Pro::Processing::Executor
#periodic Karafka::Pro::Processing::JobsBuilder
#periodic_job Karafka::Pro::Routing::Features::PeriodicJob::Topic
#periodic_job? Karafka::Pro::Routing::Features::PeriodicJob::Topic
#permission_type Karafka::Admin::Acl
persist Karafka::ActiveJob::CurrentAttributes
#pid Karafka::Swarm::Node
#ping Karafka::Connection::Client
#pipe_async Karafka::Pro::Processing::Piping::Consumer
#pipe_many_async Karafka::Pro::Processing::Piping::Consumer
#pipe_many_sync Karafka::Pro::Processing::Piping::Consumer
#pipe_sync Karafka::Pro::Processing::Piping::Consumer
#polled Karafka::Connection::RawMessagesBuffer
#pop Karafka::Processing::JobsQueue
#pop Karafka::Processing::TimedQueue
#pop_tags Karafka::Instrumentation::Vendors::Datadog::LoggerListener
post_setup Karafka::Pro::Cleaner
post_setup Karafka::Pro::Encryption
post_setup Karafka::Pro::RecurringTasks
post_setup Karafka::Pro::ScheduledMessages
post_setup Karafka::Pro::Routing::Features::Swarm
post_setup Karafka::Routing::Features::InlineInsights
post_setup Karafka::Pro::Routing::Features::Multiplexing
post_setup Karafka::Pro::Routing::Features::OffsetMetadata
post_setup_all Karafka::Pro::Loader
post_setup_all Karafka::Routing::Features::Base
pre_setup Karafka::Pro::Cleaner
pre_setup Karafka::Pro::Encryption
pre_setup Karafka::Pro::RecurringTasks
pre_setup Karafka::Pro::ScheduledMessages
pre_setup Karafka::Pro::Routing::Features::Multiplexing
pre_setup_all Karafka::Pro::Loader
pre_setup_all Karafka::Routing::Features::Base
prepare_and_verify Karafka::Licenser
#prepended Karafka::Routing::Features::Base::Expander
#present? Karafka::Connection::MessagesBuffer
#previous_time Karafka::Pro::RecurringTasks::Task
#principal Karafka::Admin::Acl
pro? Karafka
#processed_at Karafka::Messages::BatchMetadata
#processing_lag Karafka::Messages::BatchMetadata
#processing_time_p95 Karafka::Pro::Instrumentation::PerformanceTracker
producer Karafka
#producer Karafka::BaseConsumer
producer Karafka::Setup::AttributesMap
#push Karafka::Processing::TimedQueue
#push_tags Karafka::Instrumentation::Vendors::Datadog::LoggerListener
#query_watermark_offsets Karafka::Connection::Proxy
quiet Karafka::Server
quiet Karafka::Embedded
#quiet Karafka::Swarm::Node
#quiet Karafka::Swarm::Manager
rails? Karafka
#rails? Karafka::Cli::Install
rails_console Karafka::Cli::Console
#raw_headers Karafka::Messages::Metadata
#raw_key Karafka::Messages::Metadata
#raw_payload Karafka::Messages::Message
#raw_payloads Karafka::Messages::Messages
read_lags_with_offsets Karafka::Admin
#read_only? Karafka::Admin::Configs::Config
read_topic Karafka::Admin
read_watermark_offsets Karafka::Admin
#rebalance_manager Karafka::Connection::Client
#received_at Karafka::Messages::Metadata
#recurring_tasks Karafka::Pro::Routing::Features::RecurringTasks::Topic
#recurring_tasks Karafka::Pro::Routing::Features::RecurringTasks::Builder
#recurring_tasks? Karafka::Pro::Routing::Features::RecurringTasks::Topic
#red Karafka::Helpers::Colorize
#reducer Karafka::Pro::Routing::Features::VirtualPartitions::Config
#refresh Karafka::Routing::SubscriptionGroup
refresh! Karafka
#refresh! Karafka::Pro::Processing::Collapser
#regexp Karafka::Pro::Routing::Features::Patterns::Pattern
#regexp_string Karafka::Pro::Routing::Features::Patterns::Pattern
#register Karafka::Connection::Manager
#register Karafka::Processing::JobsQueue
#register Karafka::Pro::Connection::Manager
#register Karafka::Pro::Processing::JobsQueue
#register Karafka::Pro::Processing::OffsetMetadata::Fetcher
#register Karafka::Pro::Processing::Coordinators::VirtualOffsetManager
#register_exclusions Karafka::Cli::Server
#register_inclusions Karafka::Cli::Server
#register_probe Karafka::Instrumentation::Vendors::Appsignal::Client
#regular? Karafka::Pro::Routing::Features::Patterns::Config
#reload! Top Level Namespace
#remaining Karafka::TimeTrackers::Poll
#remap Karafka::Connection::MessagesBuffer
rename_consumer_group Karafka::Admin
#replay Karafka::Pro::RecurringTasks::Executor
#replaying? Karafka::Pro::RecurringTasks::Executor
#replication_factor Karafka::Routing::Features::Declaratives::Config
#report_aggregated_topics_metrics Karafka::Instrumentation::Vendors::Appsignal::MetricsListener
#report_error Karafka::Instrumentation::Vendors::Appsignal::Client
#report_metric Karafka::Instrumentation::Vendors::Appsignal::MetricsListener
require_all Karafka::Pro::Loader
#required Karafka::Pro::Routing::Features::InlineInsights::Config
#reset Karafka::Connection::Client
#reset Karafka::TimeTrackers::Pause
#reset Karafka::Helpers::IntervalRunner
#reset Karafka::Processing::CoordinatorsBuffer
#reset! Karafka::Status
#reset! Karafka::Connection::Status
#resource_name Karafka::Admin::Acl
#resource_pattern_type Karafka::Admin::Acl
#resource_type Karafka::Admin::Acl
#respond_to_missing? Karafka::Env
#respond_to_missing? Karafka::Routing::Proxy
#resume Karafka::Connection::Client
#resume Karafka::TimeTrackers::Pause
#resume Karafka::Connection::PausesManager
#resume Karafka::Processing::CoordinatorsBuffer
#resume Karafka::Pro::Processing::SubscriptionGroupsCoordinator
#retryable? Karafka::TimeTrackers::Poll
#revoke Karafka::Processing::Coordinator
#revoke Karafka::Processing::ExecutorsBuffer
#revoke Karafka::Processing::CoordinatorsBuffer
#revoked Karafka::Processing::Executor
#revoked Karafka::Processing::JobsBuilder
#revoked Karafka::Pro::Processing::JobsBuilder
#revoked? Karafka::Processing::Coordinator
#revoked_partitions Karafka::Connection::RebalanceManager
root Karafka
run Karafka::Server
#run Karafka::Swarm::Supervisor
#safety_margin Karafka::Pro::Routing::Features::AdaptiveIterator::Config
schedule Karafka::Pro::RecurringTasks
schedule Karafka::Pro::ScheduledMessages
#schedule Karafka::Pro::RecurringTasks::Schedule
schedule Karafka::Pro::ScheduledMessages::Proxy
schedule Karafka::Pro::RecurringTasks::Dispatcher
#schedule Karafka::Pro::RecurringTasks::Serializer
#schedule_consumption Karafka::Pro::Processing::Schedulers::Base
#schedule_fifo Karafka::Pro::Processing::Schedulers::Base
#schedule_fifo Karafka::Pro::Processing::Schedulers::Default
#scheduled_at Karafka::Messages::BatchMetadata
#scheduled_messages Karafka::Pro::Routing::Features::ScheduledMessages::Topic
#scheduled_messages Karafka::Pro::Routing::Features::ScheduledMessages::Builder
#scheduled_messages? Karafka::Pro::Routing::Features::ScheduledMessages::Topic
#scope Karafka::Instrumentation::Vendors::Datadog::MetricsListener::RdKafkaMetric
#scope Karafka::Instrumentation::Vendors::Appsignal::MetricsListener::RdKafkaMetric
#seek Karafka::Connection::Client
seek_consumer_group Karafka::Admin
#seek_offset Karafka::Processing::Coordinator
#sensitive? Karafka::Admin::Configs::Config
#serialize_job Karafka::ActiveJob::CurrentAttributes::Persistence
#setup Karafka::Setup::Dsl
setup Karafka::Setup::Config
#setup Karafka::Instrumentation::Vendors::Appsignal::Base
#setup Karafka::Instrumentation::Vendors::Datadog::LoggerListener
#setup Karafka::Instrumentation::Vendors::Datadog::MetricsListener
#shared_mutex Karafka::Pro::Processing::Coordinator
#shutdown Karafka::Connection::Listener
#shutdown Karafka::Processing::Executor
#shutdown Karafka::Processing::JobsBuilder
#signal Karafka::Swarm::Node
#signal Karafka::Swarm::Pidfd
#signal Karafka::Swarm::Manager
#signal Karafka::Connection::Conductor
#size Karafka::Messages::Messages
#size Karafka::Messages::BatchMetadata
#size Karafka::Processing::WorkersBatch
#size Karafka::Connection::MessagesBuffer
#size Karafka::Connection::RawMessagesBuffer
#size Karafka::Pro::ScheduledMessages::DailyBuffer
#size Karafka::Pro::Processing::Coordinators::ErrorsTracker
start Karafka::Cli
start Karafka::Server
start Karafka::Embedded
#start Karafka::Swarm::Node
#start Karafka::Swarm::Manager
#start Karafka::TimeTrackers::Poll
#start Karafka::Processing::Coordinator
#start Karafka::Pro::Processing::Coordinator
#start! Karafka::Connection::Listener
#start_transaction Karafka::Instrumentation::Vendors::Appsignal::Client
#starts_at Karafka::Pro::ScheduledMessages::Day
#state Karafka::Pro::ScheduledMessages::Tracker
#state Karafka::Pro::ScheduledMessages::Dispatcher
#state Karafka::Pro::ScheduledMessages::Serializer
#statistics Karafka::Processing::JobsQueue
#status Karafka::Swarm::Node
stop Karafka::Server
stop Karafka::Embedded
#stop Karafka::Swarm::Node
#stop Karafka::Pro::Iterator
#stop Karafka::Swarm::Manager
#stop Karafka::Connection::Client
#stop! Karafka::Connection::Status
#stop_current_partition Karafka::Pro::Iterator
#stop_partition Karafka::Pro::Iterator
#stop_transaction Karafka::Instrumentation::Vendors::Appsignal::Client
#stopped? Karafka::Swarm::Manager
#store_offset Karafka::Connection::Proxy
#store_offset Karafka::Connection::Client
#store_offset_metadata Karafka::Pro::Processing::Strategies::Default
#strategies Karafka::Processing::StrategySelector
#strategies Karafka::Pro::Processing::StrategySelector
#strategy Karafka::Routing::Features::DeadLetterQueue::Config
#subscription_group Karafka::Routing::Topic
#subscription_group Karafka::Connection::Client
#subscription_group Karafka::Connection::Listener
#subscription_group= Karafka::Routing::ConsumerGroup
#subscription_group_details Karafka::Routing::Topic
subscription_groups Karafka::App
#subscription_groups Karafka::Routing::ConsumerGroup
#subscription_groups_coordinator Karafka::Pro::BaseConsumer
#subscription_name Karafka::Routing::Topic
#subscription_name Karafka::Pro::Routing::Features::Patterns::Topic
#subscriptions Karafka::Routing::SubscriptionGroup
#subscriptions Karafka::Pro::Routing::Features::DirectAssignments::SubscriptionGroup
#success! Karafka::Processing::Result
#success! Karafka::Processing::Coordinator
#success? Karafka::Processing::Result
#success? Karafka::Processing::Coordinator
#supervise Karafka::Process
#supervised? Karafka::Process
supported? Karafka::Swarm
supported? Karafka::Swarm::Pidfd
#swarm Karafka::Pro::Routing::Features::Swarm::Topic
#swarm? Karafka::Pro::Routing::Features::Swarm::Topic
#synchronize Karafka::Processing::Coordinator
#synchronize Karafka::Pro::Processing::Strategies::Vp::Default
#synchronize Karafka::Pro::Processing::Strategies::Lrj::Default
#synonym? Karafka::Admin::Configs::Config
#synonyms Karafka::Admin::Configs::Config
#target Karafka::Routing::Proxy
#tasks Karafka::Pro::RecurringTasks::Schedule
#terminate Karafka::Swarm::Node
#terminate Karafka::Swarm::Manager
#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
#tick Karafka::Pro::RecurringTasks::Consumer
#tick Karafka::Pro::ScheduledMessages::Consumer
#timeout Karafka::Pro::Processing::Filters::Base
#timeout Karafka::Pro::Processing::Filters::Delayer
#timeout Karafka::Pro::Processing::Filters::Throttler
#timeout Karafka::Pro::Processing::Coordinators::FiltersApplier
#timeout Karafka::Pro::Processing::Filters::InlineInsightsDelayer
#timestamp Karafka::Messages::Metadata
#to_a Karafka::Messages::Messages
#to_h Karafka::Routing::Topic
#to_h Karafka::Routing::ConsumerGroup
#to_h Karafka::Pro::RecurringTasks::Task
#to_h Karafka::Routing::ActivityManager
#to_h Karafka::Routing::Features::Eofed::Topic
#to_h Karafka::Pro::Routing::Features::Swarm::Topic
#to_h Karafka::Routing::Features::ActiveJob::Topic
#to_h Karafka::Pro::Routing::Features::Delaying::Topic
#to_h Karafka::Pro::Routing::Features::Expiring::Topic
#to_h Karafka::Pro::Routing::Features::Patterns::Topic
#to_h Karafka::Routing::Features::Declaratives::Topic
#to_h Karafka::Pro::Routing::Features::Filtering::Topic
#to_h Karafka::Routing::Features::Deserializers::Topic
#to_h Karafka::Pro::Routing::Features::Filtering::Config
#to_h Karafka::Pro::Routing::Features::Patterns::Pattern
#to_h Karafka::Pro::Routing::Features::Throttling::Topic
#to_h Karafka::Routing::Features::InlineInsights::Topic
#to_h Karafka::Pro::Routing::Features::PeriodicJob::Topic
#to_h Karafka::Routing::Features::DeadLetterQueue::Topic
#to_h Karafka::Pro::Routing::Features::OffsetMetadata::Topic
#to_h Karafka::Pro::Routing::Features::RecurringTasks::Topic
#to_h Karafka::Pro::Routing::Features::LongRunningJob::Topic
#to_h Karafka::Pro::Routing::Features::AdaptiveIterator::Topic
#to_h Karafka::Pro::Routing::Features::Patterns::ConsumerGroup
#to_h Karafka::Pro::Routing::Features::DirectAssignments::Topic
#to_h Karafka::Pro::Routing::Features::ScheduledMessages::Topic
#to_h Karafka::Pro::Routing::Features::VirtualPartitions::Topic
#to_h Karafka::Routing::Features::ManualOffsetManagement::Topic
#to_i Karafka::Pro::ScheduledMessages::MaxEpoch
#to_native_hash Karafka::Admin::Acl
#to_native_hash Karafka::Admin::Configs::Config
#to_native_hash Karafka::Admin::Configs::Resource
#to_s Karafka::Status
#to_s Karafka::Routing::SubscriptionGroup
#to_s Karafka::Pro::ScheduledMessages::State
#today= Karafka::Pro::ScheduledMessages::Tracker
tombstone Karafka::Pro::ScheduledMessages::Proxy
#tombstone? Karafka::Messages::Message
#topic Karafka::Messages::Seek
#topic Karafka::Messages::Metadata
#topic Karafka::Processing::Coordinator
#topic Karafka::Messages::BatchMetadata
#topic Karafka::Pro::Routing::Features::Patterns::Pattern
#topic Karafka::Routing::Features::DeadLetterQueue::Config
#topic= Karafka::Routing::ConsumerGroup
topic_info Karafka::Admin
topic_unique_key Karafka::Contracts::ConsumerGroup
#topic_unique_key Karafka::Pro::Routing::Features::Multiplexing::Patches::Contracts::ConsumerGroup
#topics Karafka::Routing::ConsumerGroup
#topics Karafka::Routing::SubscriptionGroup
#track Karafka::Pro::ScheduledMessages::Tracker
#track Karafka::Pro::Processing::AdaptiveIterator::Tracker
#transaction Karafka::Pro::Processing::Strategies::Default
#transactional Karafka::Routing::Features::DeadLetterQueue::Config
#trigger Karafka::Pro::RecurringTasks::Task
#ttl Karafka::Pro::Routing::Features::Expiring::Config
#type Karafka::Admin::Configs::Resource
#type Karafka::Pro::Routing::Features::Patterns::Config
#type Karafka::Instrumentation::Vendors::Datadog::MetricsListener::RdKafkaMetric
#type Karafka::Instrumentation::Vendors::Appsignal::MetricsListener::RdKafkaMetric
#unhealthy Karafka::Swarm::Node
#uniq! Karafka::Connection::RawMessagesBuffer
#unlock Karafka::Pro::Processing::JobsQueue
#unlock_async Karafka::Pro::Processing::JobsQueue
#update Karafka::Pro::ScheduledMessages::MaxEpoch
#update_state Karafka::Pro::RecurringTasks::Executor
#validate! Karafka::Contracts::Base
#validate! Karafka::Pro::Routing::Features::Swarm::Contracts::Routing
#value Karafka::Admin::Configs::Config
verify! Karafka::Constraints
#version Karafka::Pro::RecurringTasks::Schedule
#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::Connection::Conductor
#wait Karafka::Processing::JobsQueue
#wait Karafka::Pro::Processing::JobsQueue
warmup Karafka::App
with_admin Karafka::Admin
with_consumer Karafka::Admin
#with_deserialized_job Karafka::ActiveJob::CurrentAttributes::Loading
workers Karafka::Server
#wrapped Karafka::Connection::Proxy
#yellow Karafka::Helpers::Colorize