Class: Sbmt::KafkaConsumer::Routing::ConsumerMapper::Base

Inherits:

Object

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

Defined in:

lib/sbmt/kafka_consumer/routing/consumer_mapper/base.rb

Direct Known Subclasses

KarafkaV1ConsumerMapper, KarafkaV2ConsumerMapper

Instance Method Summary

• #call(raw_consumer_group_name) ⇒ String

  Remapped final consumer group name.

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

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

def call(raw_consumer_group_name)
  raise "Implement #call in a subclass"
end