Fix setup calls

flipp-oss · Dec 11, 2024 · 9170520 · 9170520
1 parent f1a714c
commit 9170520
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/lib/deimos.rb b/lib/deimos.rb
@@ -139,6 +139,9 @@ def start_outbox_backend!(thread_count: 1)
 
     def setup_karafka
       Karafka.producer.middleware.append(Deimos::ProducerMiddleware)
+      # for multiple setup calls
+      Karafka.producer.config.kafka =
+        Karafka::Setup::AttributesMap.producer(Karafka::Setup::Config.config.kafka.dup)
       EVENT_TYPES.each { |type| Karafka.monitor.notifications_bus.register_event(type) }
 
       Karafka.producer.monitor.subscribe('error.occurred') do |event|

diff --git a/lib/deimos/version.rb b/lib/deimos/version.rb
@@ -1,5 +1,5 @@
 # frozen_string_literal: true
 
 module Deimos
-  VERSION = '2.0.0-alpha6'
+  VERSION = '2.0.0-alpha7'
 end