Documentation for karafka/karafka (master)

Alphabetic Index

File Listing

README

Namespace Listing A-Z

Top Level Namespace

ActiveJob (Karafka::Pro::Routing::Features)
ActiveJob (Karafka::Pro)
ActiveJob (Karafka)
ActiveJob (Karafka::Routing::Features)
ActiveJob
ActivityManager (Karafka::Routing)
Admin (Karafka)
Aj (Karafka::Pro::Processing::Strategies)
AjDlqMom (Karafka::Processing::Strategies)
AjMom (Karafka::Processing::Strategies)
App (Karafka)
Async (Karafka::Helpers)
AttributesMap (Karafka::Setup)

Base (Karafka::Pro::Processing::Strategies)
Base (Karafka::Pro::Processing::Filters)
Base (Karafka::Processing::Strategies)
Base (Karafka::Cli)
Base (Karafka::Routing::Features)
Base (Karafka::Pro::Contracts)
Base (Karafka::Pro::Routing::Features)
Base (Karafka::TimeTrackers)
Base (Karafka::Contracts)
Base (Karafka::Processing::Jobs)
BaseConsumer (Karafka)
BatchMetadata (Karafka::Messages)
BatchMetadata (Karafka::Messages::Builders)
Bindings (Karafka::Patches::Rdkafka)
Builder (Karafka::Pro::Routing::Features::Patterns)
Builder (Karafka::Pro::Routing::Features::ActiveJob)
Builder (Karafka::Routing::Features::ActiveJob)
Builder (Karafka::Routing)
Builders (Karafka::Messages)

Callbacks (Karafka::Instrumentation)
Cipher (Karafka::Pro::Encryption)
Cleaner (Karafka::Pro)
Cli (Karafka)
Client (Karafka::Connection)
Collapser (Karafka::Pro::Processing)
Colorize (Karafka::Helpers)
Config (Karafka::Pro::Encryption::Setup)
Config (Karafka::Contracts)
Config (Karafka::Pro::Routing::Features::Throttling)
Config (Karafka::Routing::Features::ManualOffsetManagement)
Config (Karafka::Setup)
Config (Karafka::Pro::Encryption::Contracts)
Config (Karafka::Pro::Routing::Features::Expiring)
Config (Karafka::Routing::Features::InlineInsights)
Config (Karafka::Routing::Features::Declaratives)
Config (Karafka::Pro::Routing::Features::Delaying)
Config (Karafka::Routing::Features::DeadLetterQueue)
Config (Karafka::Pro::Routing::Features::Patterns)
Config (Karafka::Pro::Routing::Features::VirtualPartitions)
Config (Karafka::Pro::Routing::Features::Filtering)
Config (Karafka::Pro::Routing::Features::LongRunningJob)
Config (Karafka::Routing::Features::ActiveJob)
Connection (Karafka)
Console (Karafka::Cli)
Consume (Karafka::Processing::Jobs)
ConsumeNonBlocking (Karafka::Pro::Processing::Jobs)
Consumer (Karafka::ActiveJob)
Consumer (Karafka::Processing::InlineInsights)
Consumer (Karafka::Pro::ActiveJob)
ConsumerGroup (Karafka::Pro::Routing::Features::Patterns)
ConsumerGroup (Karafka::Contracts)
ConsumerGroup (Karafka::Pro::Routing::Features::Patterns::Contracts)
ConsumerGroup (Karafka::Routing)
ConsumerGroupCoordinator (Karafka::Connection)
ConsumerMapper (Karafka::Routing)
Contracts (Karafka::Pro::Routing::Features::LongRunningJob)
Contracts (Karafka::Pro::Encryption)
Contracts (Karafka::Routing::Features::InlineInsights)
Contracts (Karafka::Routing::Features::ActiveJob)
Contracts (Karafka::Routing::Features::ManualOffsetManagement)
Contracts (Karafka::Pro::Routing::Features::Throttling)
Contracts (Karafka::Pro::Routing::Features::Pausing)
Contracts (Karafka::Pro::Routing::Features::Patterns)
Contracts (Karafka::Routing::Features::DeadLetterQueue)
Contracts (Karafka::Pro::Routing::Features::VirtualPartitions)
Contracts (Karafka)
Contracts (Karafka::Pro::Routing::Features::Delaying)
Contracts (Karafka::Pro::Routing::Features::Filtering)
Contracts (Karafka::Pro)
Contracts (Karafka::Routing::Features::Declaratives)
Contracts (Karafka::Pro::Routing::Features::Expiring)
Contracts (Karafka::Pro::Routing::Features::DeadLetterQueue)
Coordinator (Karafka::Processing)
Coordinator (Karafka::Pro::Processing)
CoordinatorsBuffer (Karafka::Processing)
CurrentAttributes (Karafka::ActiveJob)

Datadog (Karafka::Instrumentation::Vendors)
DeadLetterQueue (Karafka::Routing::Features)
DeadLetterQueue (Karafka::Pro::Routing::Features)
Declaratives (Karafka::Routing::Features)
Default (Karafka::Pro::Processing::Strategies::Vp)
Default (Karafka::Pro::Processing::Strategies::Mom)
Default (Karafka::Pro::Processing::Strategies::Dlq)
Default (Karafka::Pro::Processing::Strategies::Ftr)
Default (Karafka::Pro::Processing::Strategies::Lrj)
Default (Karafka::Processing::Strategies)
Default (Karafka::Pro::Processing::Strategies)
Delayer (Karafka::Pro::Processing::Filters)
Delaying (Karafka::Pro::Routing::Features)
Deserializer (Karafka::Serialization::Json)
Detector (Karafka::Pro::Routing::Features::Patterns)
Dispatcher (Karafka::ActiveJob)
Dispatcher (Karafka::Pro::ActiveJob)
Dlq (Karafka::Processing::Strategies)
Dlq (Karafka::Pro::Processing::Strategies)
DlqFtrLrjMom (Karafka::Pro::Processing::Strategies::Aj)
DlqFtrLrjMomVp (Karafka::Pro::Processing::Strategies::Aj)
DlqFtrMom (Karafka::Pro::Processing::Strategies::Aj)
DlqFtrMomVp (Karafka::Pro::Processing::Strategies::Aj)
DlqLrjMom (Karafka::Pro::Processing::Strategies::Aj)
DlqLrjMomVp (Karafka::Pro::Processing::Strategies::Aj)
DlqMom (Karafka::Processing::Strategies)
DlqMom (Karafka::Pro::Processing::Strategies::Aj)
DlqMomVp (Karafka::Pro::Processing::Strategies::Aj)
Dsl (Karafka::Setup)

Embedded (Karafka)
Encryption (Karafka::Pro)
Env (Karafka)
Error (Karafka::Instrumentation::Callbacks)
Errors (Karafka::Pro::Cleaner)
Errors (Karafka)
Errors (Karafka::Pro::Encryption)
Executor (Karafka::Processing)
ExecutorsBuffer (Karafka::Processing)
Expander (Karafka::Routing::Features::Base)
Expander (Karafka::Pro::Iterator)
ExpansionsSelector (Karafka::Processing)
Expirer (Karafka::Pro::Processing::Filters)
Expiring (Karafka::Pro::Routing::Features)

Features (Karafka::Routing)
Features (Karafka::Pro::Routing)
Filtering (Karafka::Pro::Routing::Features)
Filters (Karafka::Pro::Processing)
FiltersApplier (Karafka::Pro::Processing)
Ftr (Karafka::Pro::Processing::Strategies)
Ftr (Karafka::Pro::Processing::Strategies::Dlq)
Ftr (Karafka::Pro::Processing::Strategies::Mom)
Ftr (Karafka::Pro::Processing::Strategies::Lrj)
FtrLrj (Karafka::Pro::Processing::Strategies::Dlq)
FtrLrjMom (Karafka::Pro::Processing::Strategies::Dlq)
FtrLrjMom (Karafka::Pro::Processing::Strategies::Aj)
FtrLrjMomVp (Karafka::Pro::Processing::Strategies::Dlq)
FtrLrjMomVp (Karafka::Pro::Processing::Strategies::Aj)
FtrLrjVp (Karafka::Pro::Processing::Strategies::Dlq)
FtrMom (Karafka::Pro::Processing::Strategies::Lrj)
FtrMom (Karafka::Pro::Processing::Strategies::Dlq)
FtrMom (Karafka::Pro::Processing::Strategies::Aj)
FtrMomVp (Karafka::Pro::Processing::Strategies::Dlq)
FtrMomVp (Karafka::Pro::Processing::Strategies::Lrj)
FtrMomVp (Karafka::Pro::Processing::Strategies::Aj)
FtrVp (Karafka::Pro::Processing::Strategies::Dlq)
FtrVp (Karafka::Pro::Processing::Strategies::Mom)
FtrVp (Karafka::Pro::Processing::Strategies::Lrj)

Helpers (Karafka)

Idle (Karafka::Processing::Jobs)
Info (Karafka::Cli)
InlineInsights (Karafka::Processing)
InlineInsights (Karafka::Routing::Features)
Install (Karafka::Cli)
Instrumentation (Karafka)
Iterator (Karafka::Pro)

JobExtensions (Karafka::ActiveJob)
JobOptionsContract (Karafka::ActiveJob)
JobOptionsContract (Karafka::Pro::ActiveJob)
Jobs (Karafka::Pro::Processing)
Jobs (Karafka::Processing)
JobsBuilder (Karafka::Pro::Processing)
JobsBuilder (Karafka::Processing)
JobsQueue (Karafka::Processing)
Json (Karafka::Serialization)

Karafka
KarafkaAdapter (ActiveJob::QueueAdapters)
Kubernetes (Karafka::Instrumentation::Vendors)

Licenser (Karafka)
Listener (Karafka::Processing::InlineInsights)
Listener (Karafka::Connection)
ListenersBatch (Karafka::Connection)
LivenessListener (Karafka::Instrumentation::Vendors::Kubernetes)
Loader (Karafka::Pro)
Loading (Karafka::ActiveJob::CurrentAttributes)
Logger (Karafka::Instrumentation)
LoggerListener (Karafka::Instrumentation::Vendors::Datadog)
LoggerListener (Karafka::Instrumentation)
LongRunningJob (Karafka::Pro::Routing::Features)
Lrj (Karafka::Pro::Processing::Strategies::Dlq)
Lrj (Karafka::Pro::Processing::Strategies)
LrjMom (Karafka::Pro::Processing::Strategies::Dlq)
LrjMom (Karafka::Pro::Processing::Strategies::Aj)
LrjMomVp (Karafka::Pro::Processing::Strategies::Dlq)
LrjMomVp (Karafka::Pro::Processing::Strategies::Aj)
LrjVp (Karafka::Pro::Processing::Strategies::Dlq)

ManualOffsetManagement (Karafka::Routing::Features)
Message (Karafka::Pro::Cleaner::Messages)
Message (Karafka::Messages)
Message (Karafka::Messages::Builders)
Messages (Karafka::Pro::Encryption)
Messages (Karafka::Messages)
Messages (Karafka::Messages::Builders)
Messages (Karafka::Pro::Cleaner::Messages)
Messages (Karafka::Pro::Cleaner)
Messages (Karafka)
MessagesBuffer (Karafka::Connection)
Metadata (Karafka::Messages)
MetricsListener (Karafka::Instrumentation::Vendors::Datadog)
Middleware (Karafka::Pro::Encryption::Messages)
Mom (Karafka::Pro::Processing::Strategies::Lrj)
Mom (Karafka::Pro::Processing::Strategies::Aj)
Mom (Karafka::Pro::Processing::Strategies::Dlq)
Mom (Karafka::Processing::Strategies)
Mom (Karafka::Pro::Processing::Strategies)
MomVp (Karafka::Pro::Processing::Strategies::Aj)
MomVp (Karafka::Pro::Processing::Strategies::Dlq)
MomVp (Karafka::Pro::Processing::Strategies::Lrj)
Monitor (Karafka::Instrumentation)
MultiDelegator (Karafka::Helpers)

Notifications (Karafka::Instrumentation)

Parser (Karafka::Pro::Encryption::Messages)
Parser (Karafka::Messages)
Partitioner (Karafka::Pro::Processing)
Partitioner (Karafka::Processing)
Patches (Karafka)
Pattern (Karafka::Pro::Routing::Features::Patterns::Contracts)
Pattern (Karafka::Pro::Routing::Features::Patterns)
Patterns (Karafka::Pro::Routing::Features::Patterns)
Patterns (Karafka::Pro::Routing::Features)
Pause (Karafka::TimeTrackers)
PausesManager (Karafka::Connection)
Pausing (Karafka::Pro::Routing::Features)
PerformanceTracker (Karafka::Pro)
Persistence (Karafka::ActiveJob::CurrentAttributes)
Poll (Karafka::TimeTrackers)
Pro (Karafka)
Process (Karafka)
Processing (Karafka)
Processing (Karafka::Pro)
ProctitleListener (Karafka::Instrumentation)
Proxy (Karafka::Routing::Features::ActiveJob)
Proxy (Karafka::Connection)
Proxy (Karafka::Routing)

QueueAdapters (ActiveJob)

Railtie (Karafka)
RawMessagesBuffer (Karafka::Connection)
RdKafkaMetric (Karafka::Instrumentation::Vendors::Datadog::MetricsListener)
Rdkafka (Karafka::Patches)
RebalanceManager (Karafka::Connection)
Result (Karafka::Processing)
Revoked (Karafka::Processing::Jobs)
RevokedNonBlocking (Karafka::Pro::Processing::Jobs)
Router (Karafka::Routing)
Routing (Karafka::Pro)
Routing (Karafka)
Runner (Karafka)

Scheduler (Karafka::Pro::Processing)
Scheduler (Karafka::Processing)
Seek (Karafka::Messages)
Serialization (Karafka)
Server (Karafka::Cli)
Server (Karafka)
ServerCliOptions (Karafka::Pro::Contracts)
ServerCliOptions (Karafka::Contracts)
Setup (Karafka)
Setup (Karafka::Pro::Encryption)
Shutdown (Karafka::Processing::Jobs)
Statistics (Karafka::Instrumentation::Callbacks)
Status (Karafka)
Strategies (Karafka::Processing)
Strategies (Karafka::Pro::Processing)
StrategySelector (Karafka::Pro::Processing)
StrategySelector (Karafka::Processing)
SubscriptionGroup (Karafka::Routing)
SubscriptionGroupsBuilder (Karafka::Routing)

Throttler (Karafka::Pro::Processing::Filters)
Throttling (Karafka::Pro::Routing::Features)
TimeTrackers (Karafka)
Topic (Karafka::Pro::Routing::Features::Filtering)
Topic (Karafka::Routing::Features::Declaratives)
Topic (Karafka::Pro::Routing::Features::Delaying)
Topic (Karafka::Pro::Routing::Features::Expiring)
Topic (Karafka::Pro::Routing::Features::Throttling)
Topic (Karafka::Routing::Features::InlineInsights)
Topic (Karafka::Pro::Routing::Features::Pausing)
Topic (Karafka::Routing::Features::ActiveJob)
Topic (Karafka::Pro::Routing::Features::Patterns)
Topic (Karafka::Routing::Features::ManualOffsetManagement)
Topic (Karafka::Routing::Features::ManualOffsetManagement::Contracts)
Topic (Karafka::Pro::Routing::Features::DeadLetterQueue::Contracts)
Topic (Karafka::Routing::Features::DeadLetterQueue::Contracts)
Topic (Karafka::Pro::Routing::Features::LongRunningJob::Contracts)
Topic (Karafka::Routing::Features::InlineInsights::Contracts)
Topic (Karafka::Pro::Routing::Features::Filtering::Contracts)
Topic (Karafka::Pro::Routing::Features::Throttling::Contracts)
Topic (Karafka::Pro::Routing::Features::VirtualPartitions::Contracts)
Topic (Karafka::Pro::Routing::Features::Delaying::Contracts)
Topic (Karafka::Routing::Features::ActiveJob::Contracts)
Topic (Karafka::Pro::Routing::Features::Pausing::Contracts)
Topic (Karafka::Pro::Routing::Features::Expiring::Contracts)
Topic (Karafka::Pro::Routing::Features::Patterns::Contracts)
Topic (Karafka::Routing::Features::Declaratives::Contracts)
Topic (Karafka::Contracts)
Topic (Karafka::Routing)
Topic (Karafka::Routing::Features::DeadLetterQueue)
Topic (Karafka::Pro::Routing::Features::VirtualPartitions)
Topic (Karafka::Pro::Routing::Features::LongRunningJob)
Topics (Karafka::Pro::Routing::Features::Patterns)
Topics (Karafka::Cli)
Topics (Karafka::Routing)
TplBuilder (Karafka::Pro::Iterator)
Tracker (Karafka::Processing::InlineInsights)

Vendors (Karafka::Instrumentation)
VirtualLimiter (Karafka::Pro::Processing::Filters)
VirtualOffsetManager (Karafka::Pro::Processing)
VirtualPartitions (Karafka::Pro::Routing::Features)
Vp (Karafka::Pro::Processing::Strategies)
Vp (Karafka::Pro::Processing::Strategies::Mom)
Vp (Karafka::Pro::Processing::Strategies::Ftr)
Vp (Karafka::Pro::Processing::Strategies::Dlq)
Vp (Karafka::Pro::Processing::Strategies::Lrj)

Worker (Karafka::Processing)
WorkersBatch (Karafka::Processing)