lib/water_drop/producer_proxy.rb in waterdrop-0.3.2 vs lib/water_drop/producer_proxy.rb in waterdrop-0.3.2.1

@@ -52,10 +52,10 @@
     end
 
     # @return [Kafka::Producer] producer instance to which we can forward method requests
     def producer
       reload! if dead?
-      @producer ||= Kafka.new(seed_brokers: ::WaterDrop.config.kafka_hosts).producer
+      @producer ||= Kafka.new(seed_brokers: ::WaterDrop.config.kafka.hosts).producer
     end
 
     # @return [Boolean] true if we cannot use producer anymore because it was not used for a
     #   long time
     def dead?