lib/kafka/datadog.rb in ruby-kafka-0.5.1 vs lib/kafka/datadog.rb in ruby-kafka-0.5.2.beta1

@@ -227,10 +227,14 @@
         }
 
         # This gets us the write rate.
         increment("producer.produce.messages", tags: tags.merge(topic: topic))
 
+        # Information about typical/average/95p message size.
         histogram("producer.produce.message_size", message_size, tags: tags.merge(topic: topic))
+
+        # Aggregate message size.
+        count("producer.produce.message_size.sum", message_size, tags: tags.merge(topic: topic))
 
         # This gets us the avg/max buffer size per producer.
         histogram("producer.buffer.size", buffer_size, tags: tags)
 
         # This gets us the avg/max buffer fill ratio per producer.