Class: Sbmt::KafkaConsumer::Config::Consumer

Inherits:
Dry::Struct
  • Object
show all
Defined in:
lib/sbmt/kafka_consumer/config/consumer.rb

Instance Method Summary collapse

Instance Method Details

#consumer_klass ⇒ Object 



9
10
11
12
13
14
15
 
# File 'lib/sbmt/kafka_consumer/config/consumer.rb', line 9

def consumer_klass
  target_klass = klass.constantize

  return target_klass.consumer_klass if init_attrs.blank?

  target_klass.consumer_klass(**init_attrs)
end