lib/karafka/fetcher.rb in karafka-0.6.0.rc1 vs lib/karafka/fetcher.rb in karafka-0.6.0.rc2

@@ -24,10 +24,10 @@
 
     private
 
     # @return [Array<Karafka::Connection::Listener>] listeners that will consume messages
     def listeners
-      @listeners ||= App.consumer_groups.map do |consumer_group|
+      @listeners ||= App.consumer_groups.active.map do |consumer_group|
         Karafka::Connection::Listener.new(consumer_group)
       end
     end
 
     # @return [Proc] proc that should be processed when a messages arrive