Module: Karafka::Routing::Router
- Defined in:
- lib/karafka/routing/router.rb
Overview
Note:
Since Kafka does not provide namespaces or modules for topics, they all have “flat” structure so all the routes are being stored in a single level array
Karafka framework Router for routing incoming messages to proper consumers
Class Method Summary collapse
-
.find(topic_id) ⇒ Karafka::Routing::Route
Find a proper topic based on full topic id.
Class Method Details
.find(topic_id) ⇒ Karafka::Routing::Route
Find a proper topic based on full topic id
16 17 18 19 20 21 22 23 24 |
# File 'lib/karafka/routing/router.rb', line 16 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 |