lib/karafka/runner.rb in karafka-2.3.0 vs lib/karafka/runner.rb in karafka-2.3.1

@@ -16,9 +16,13 @@
       jobs_queue = App.config.internal.processing.jobs_queue_class.new
 
       workers = Processing::WorkersBatch.new(jobs_queue)
       listeners = Connection::ListenersBatch.new(jobs_queue)
 
+      # We mark it prior to delegating to the manager as manager will have to start at least one
+      # connection to Kafka, hence running
+      Karafka::App.run!
+
       # Register all the listeners so they can be started and managed
       @manager.register(listeners)
 
       workers.each(&:async_call)