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

def outgoing(topic)

Returns:
  • (String, Symbol) - same topic as on input

Parameters:
  • topic (String, Symbol) -- topic 
def outgoing(topic)
  topic
end