Contents

# frozen_string_literal: true

require_relative "consumer_mapper/base"

module Sbmt
  module KafkaConsumer
    module Routing
      # karafka v2 (before 2.4) consumer group name mapper
      class KarafkaV2ConsumerMapper < ConsumerMapper::Base
        def call(raw_consumer_group_name)
          "#{Karafka::App.config.client_id}_#{raw_consumer_group_name}"
        end
      end
    end
  end
end

Version data entries

9 entries across 9 versions & 1 rubygems

Version	Path
sbmt-kafka_consumer-3.4.0	lib/sbmt/kafka_consumer/routing/karafka_v2_consumer_mapper.rb
sbmt-kafka_consumer-3.3.2	lib/sbmt/kafka_consumer/routing/karafka_v2_consumer_mapper.rb
sbmt-kafka_consumer-3.3.1	lib/sbmt/kafka_consumer/routing/karafka_v2_consumer_mapper.rb
sbmt-kafka_consumer-3.3.0	lib/sbmt/kafka_consumer/routing/karafka_v2_consumer_mapper.rb
sbmt-kafka_consumer-3.2.2	lib/sbmt/kafka_consumer/routing/karafka_v2_consumer_mapper.rb
sbmt-kafka_consumer-3.2.1	lib/sbmt/kafka_consumer/routing/karafka_v2_consumer_mapper.rb
sbmt-kafka_consumer-3.2.0	lib/sbmt/kafka_consumer/routing/karafka_v2_consumer_mapper.rb
sbmt-kafka_consumer-3.1.0	lib/sbmt/kafka_consumer/routing/karafka_v2_consumer_mapper.rb
sbmt-kafka_consumer-3.0.0	lib/sbmt/kafka_consumer/routing/karafka_v2_consumer_mapper.rb