Sha256: 04f6462c094addf6ffbea03745e7f63465d0740cbe8979a2bfb686746bfe4ec1
Contents?: true
Size: 1.39 KB
Versions: 27
Compression:
Stored size: 1.39 KB
Contents
# frozen_string_literal: true
module Karafka
module Routing
# Default topic mapper that does not remap things
# Mapper can be used for Kafka providers that require namespaced topic names. Instead of being
# provider dependent, we can then define mapper and use internally "pure" topic names in
# routes and responders
#
# @example Mapper for mapping prefixed topics
# class MyMapper
# PREFIX = "my_user_name."
#
# def incoming(topic)
# topic.to_s.gsub(PREFIX, '')
# end
#
# def outgoing(topic)
# "#{PREFIX}#{topic}"
# end
# end
#
# @example Mapper for replacing "." with "_" in topic names
# class MyMapper
# PREFIX = "my_user_name."
#
# def incoming(topic)
# topic.to_s.gsub('.', '_')
# end
#
# def outgoing(topic)
# topic.to_s.gsub('_', '.')
# end
# end
class TopicMapper
# @param topic [String, Symbol] topic
# @return [String, Symbol] same topic as on input
# @example
# incoming('topic_name') #=> 'topic_name'
def incoming(topic)
topic
end
# @param topic [String, Symbol] topic
# @return [String, Symbol] same topic as on input
# @example
# outgoing('topic_name') #=> 'topic_name'
def outgoing(topic)
topic
end
end
end
end
Version data entries
27 entries across 27 versions & 1 rubygems