Class: Karafka::Routing::ConsumerMapper

Inherits:
Object
  • Object
show all
Defined in:
lib/karafka/routing/consumer_mapper.rb

Overview

Default consumer mapper that builds consumer ids based on app id and consumer group name Different mapper can be used in case of preexisting consumer names or for applying other naming conventions not compatible with Karafka client_id + consumer name concept

Examples:

Mapper for using consumer groups without a client_id prefix

class MyMapper
  def call(raw_consumer_group_name)
    raw_consumer_group_name
  end
end

Instance Method Summary collapse

Instance Method Details

#call(raw_consumer_group_name) ⇒ String

Returns remapped final consumer group name.

Parameters:

  • raw_consumer_group_name (String, Symbol) —

    string or symbolized consumer group name

Returns:

  • (String) —

    remapped final consumer group name



18
19
20
 
# File 'lib/karafka/routing/consumer_mapper.rb', line 18

def call(raw_consumer_group_name)
  "#{Karafka::App.config.client_id}_#{raw_consumer_group_name}"
end