Class: Karafka::Processing::ExpansionsSelector

Inherits:

Object

• Object
• Karafka::Processing::ExpansionsSelector

Defined in:

lib/karafka/processing/expansions_selector.rb

Overview

Selector of appropriate topic setup based features enhancements.

Those expansions to the consumer API are NOT about the flow of processing. For this we have strategies. Those are suppose to provide certain extra APIs that user can use to get some extra non-flow related functionalities.

Direct Known Subclasses

Karafka::Pro::Processing::ExpansionsSelector

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/processing/expansions_selector.rb', line 15

def find(topic)
  expansions = []
  expansions << Processing::InlineInsights::Consumer if topic.inline_insights?
  expansions
end