lib/karafka/runner.rb in karafka-2.3.4 vs lib/karafka/runner.rb in karafka-2.4.0.beta1

@@ -23,10 +23,10 @@
       Karafka::App.run!
 
       # Register all the listeners so they can be started and managed
       @manager.register(listeners)
 
-      workers.each(&:async_call)
+      workers.each_with_index { |worker, i| worker.async_call("karafka.worker##{i}") }
 
       # We aggregate threads here for a supervised shutdown process
       Karafka::Server.workers = workers
       Karafka::Server.listeners = listeners
       Karafka::Server.jobs_queue = jobs_queue