lib/deimos/backends/db.rb in deimos-ruby-1.3.0.pre.beta5 vs lib/deimos/backends/db.rb in deimos-ruby-1.4.0.pre.beta1
- old
+ new
@@ -18,14 +18,9 @@
)
message.key = m.encoded_key.to_s.b unless producer_class.config[:no_keys]
message
end
Deimos::KafkaMessage.import(records)
- Deimos.config.metrics&.increment(
- 'db_producer.insert',
- tags: %W(topic:#{producer_class.topic}),
- by: records.size
- )
end
end
end
end
end