Class: Karafka::Pro::Routing::Features::AdaptiveIterator
- Inherits:
-
Base
- Object
- Routing::Features::Base
- Base
- Karafka::Pro::Routing::Features::AdaptiveIterator
- Defined in:
- lib/karafka/pro/routing/features/adaptive_iterator.rb,
lib/karafka/pro/routing/features/adaptive_iterator/topic.rb,
lib/karafka/pro/routing/features/adaptive_iterator/config.rb,
lib/karafka/pro/routing/features/adaptive_iterator/contracts/topic.rb
Overview
Feature that pro-actively monitors remaining time until max poll interval ms and cost of processing of each message in a batch. When there is no more time to process more messages from the batch, it will seek back so we do not reach max poll interval. It can be useful when we reach this once in a while. For a constant long-running jobs, please use the Long-Running Jobs feature instead.
It also provides some wrapping over typical operations users do, like stopping if revoked, auto-marking, etc
Defined Under Namespace
Modules: Contracts, Topic Classes: Config