Module: Karafka::Consumers::Includer

Defined in:
lib/karafka/consumers/includer.rb

Overview

Module used to inject functionalities into a given consumer instance, based on the consumer topic and its settings We don't need all the behaviors in all the cases, so it is not worth having everything in all the cases all the time

Class Method Summary collapse

Class Method Details

.call(consumer) ⇒ Object

Parameters:

  • consumer (Karafka::BaseConsumer) —

    consumer instance, that will get some functionalities based on the topic under which it operates



14
15
16
17
18
19
20
21
 
# File 'lib/karafka/consumers/includer.rb', line 14

def call(consumer)
  topic = consumer.topic

  bind_backend(consumer, topic)
  bind_params(consumer, topic)
  bind_batch_metadata(consumer, topic)
  bind_responders(consumer, topic)
end