Sha256: 32039244c4ee1eb44a4c2016a370620605797aa5a8208babcb4d2b5bf76ccbae
Contents?: true
Size: 361 Bytes
Versions: 13
Compression:
Stored size: 361 Bytes
Contents
module Sbmt
module KafkaConsumer
module Routing
class KarafkaV1ConsumerMapper < Karafka::Routing::ConsumerMapper
def call(raw_consumer_group_name)
client_id = ActiveSupport::Inflector.underscore(Karafka::App.config.client_id).tr("/", "_")
"#{client_id}_#{raw_consumer_group_name}"
end
end
end
end
end
Version data entries
13 entries across 13 versions & 1 rubygems