module Karafka::Routing::TopicMapper

def incoming(topic)

Returns:

(String, Symbol) - same topic as on input

Parameters:

topic (String, Symbol) -- topic

def incoming(topic)
  topic
end

Instance Methods