Sha256: c54254a3a9efd089c251ebabc9301380a45331ebdc2a0d81461e2e88f72fa2d6
Contents?: true
Size: 929 Bytes
Versions: 29
Compression:
Stored size: 929 Bytes
Contents
# frozen_string_literal: true
module Rimless
module Karafka
# The Karafka framework makes some assumptions about the consumer group and
# topic names. We have our own opinions/conventions, so we just pass them
# through unmodified.
class PassthroughMapper
# We do not want to modify the given consumer group name, so we
# pass it through.
#
# @param raw_consumer_group_name [String, Symbol] the original
# consumer group name
# @return [String, Symbol] the original consumer group name
def call(raw_consumer_group_name)
raw_consumer_group_name
end
# We do not want to modify the given topic name, so we pass it through.
#
# @param topic [String, Symbol] the original topic name
# @return [String, Symbol] the original topic name
def incoming(topic)
topic
end
alias outgoing incoming
end
end
end
Version data entries
29 entries across 29 versions & 1 rubygems