Class: Karafka::Pro::Routing::Features::NonBlockingJob

Inherits:
Base show all
Defined in:
lib/karafka/pro/routing/features/non_blocking_job.rb,
lib/karafka/pro/routing/features/non_blocking_job/topic.rb

Overview

Non Blocking Job is just an alias for LRJ.

We however have it as a separate feature because its use-case may vary from LRJ.

While LRJ is used mainly for long-running jobs that would take more than max poll interval time, non-blocking can be applied to make sure that we do not wait with polling of different partitions and topics that are subscribed together.

This effectively allows for better resources utilization

All the underlying code is the same but use-case is different and this should be reflected in the routing, hence this “virtual” feature.

Defined Under Namespace

Modules: Topic

Method Summary

Methods inherited from Routing::Features::Base

activate, load_all, post_setup_all, pre_setup_all