Normalize topic names by using symbols (#6)

close #3
catawiki · Mar 8, 2019 · 8fa229a · 8fa229a
1 parent fad511c
commit 8fa229a
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/lib/fake/kafka/consumer.rb b/lib/fake/kafka/consumer.rb
@@ -5,12 +5,12 @@ def initialize(kafka)
   end
 
   def subscribe(topic, **)
-    @topics << topic
+    @topics << topic.to_sym
   end
 
   def each_message(*options, &block)
     @kafka.messages.each do |message|
-      next unless @topics.include?(message.topic)
+      next unless @topics.include?(message.topic.to_sym)
 
       begin
         block.call(message)