Class: Karafka::Pro::Processing::ExpansionsSelector

Inherits:

Karafka::Processing::ExpansionsSelector

• Object
• Karafka::Processing::ExpansionsSelector
• Karafka::Pro::Processing::ExpansionsSelector

Defined in:

lib/karafka/pro/processing/expansions_selector.rb

Overview

Pro selector of appropriate topic setup based features enhancements.

Instance Method Summary

• #find(topic) ⇒ Array<Module>

  Modules with proper expansions we’re suppose to use to enhance the consumer.

Instance Method Details

#find(topic) ⇒ Array<Module>

Returns modules with proper expansions we’re suppose to use to enhance the consumer.

Parameters:

• topic (Karafka::Routing::Topic) —

  topic with settings based on which we find expansions

Returns:

• (Array<Module>) —

  modules with proper expansions we’re suppose to use to enhance the consumer

# File 'lib/karafka/pro/processing/expansions_selector.rb', line 23

def find(topic)
  # Start with the non-pro expansions
  expansions = super
  expansions << Pro::Processing::Piping::Consumer
  expansions << Pro::Processing::OffsetMetadata::Consumer if topic.offset_metadata?
  expansions << Pro::Processing::PeriodicJob::Consumer if topic.periodic_job?
  expansions
end