module Karafka::Routing::ConsumerMapper

def self.call(raw_consumer_group_name)

Returns:
  • (String) - remapped final consumer group name

Parameters:
  • raw_consumer_group_name (String, Symbol) -- string or symbolized consumer group name 
def self.call(raw_consumer_group_name)
  client_name = Dry::Inflector.new.underscore(Karafka::App.config.client_id.to_s)
  "#{client_name}_#{raw_consumer_group_name}"
end