Class: Sbmt::KafkaConsumer::Routing::KarafkaV2ConsumerMapper

Inherits:

ConsumerMapper::Base

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

Defined in:

lib/sbmt/kafka_consumer/routing/karafka_v2_consumer_mapper.rb

Overview

karafka v2 (before 2.4) consumer group name mapper

Instance Method Summary

• #call(raw_consumer_group_name) ⇒ Object

Instance Method Details

#call(raw_consumer_group_name) ⇒ Object

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

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