Class: Sbmt::KafkaConsumer::Routing::KarafkaV1ConsumerMapper

Inherits:

ConsumerMapper::Base

• Object
• ConsumerMapper::Base
• Sbmt::KafkaConsumer::Routing::KarafkaV1ConsumerMapper

Defined in:

lib/sbmt/kafka_consumer/routing/karafka_v1_consumer_mapper.rb

Instance Method Summary

• #call(raw_consumer_group_name) ⇒ Object

  karafka v1 consumer group name mapper.

Instance Method Details

#call(raw_consumer_group_name) ⇒ Object

karafka v1 consumer group name mapper

# File 'lib/sbmt/kafka_consumer/routing/karafka_v1_consumer_mapper.rb', line 10

def call(raw_consumer_group_name)
  client_id = ActiveSupport::Inflector.underscore(Karafka::App.config.client_id).tr("/", "_")
  "#{client_id}_#{raw_consumer_group_name}"
end