module Karafka::Routing::Router

def find(topic_id)

Raises:
  • (Karafka::Topic::NonMatchingTopicError) - raised if topic name does not match

Returns:
  • (Karafka::Routing::Route) - proper route details

Parameters:
  • topic_id (String) -- proper topic id (already mapped, etc) for which we want to find 
def find(topic_id)
  App.consumer_groups.each do |consumer_group|
    consumer_group.topics.each do |topic|
      return topic if topic.id == topic_id
    end
  end
  raise(Errors::NonMatchingRouteError, topic_id)
end