lib/deimos/utils/db_producer.rb in deimos-kafka-1.0.0.pre.beta17 vs lib/deimos/utils/db_producer.rb in deimos-kafka-1.0.0.pre.beta18

@@ -81,10 +81,10 @@
 
       # @param batch [Array<Hash>]
       def produce_messages(batch)
         @logger.debug("Publishing #{batch.size} messages to #{@current_topic}")
         producer.publish_list(batch)
-        Deimos.metrics&.increment(
+        Deimos.config.metrics&.increment(
           'publish',
           tags: %W(status:success topic:#{@current_topic}),
           by: batch.size
         )
         @logger.info("Sent #{batch.size} messages to #{@current_topic}")