lib/kafka/producer.rb in ruby-kafka-0.3.13.beta1 vs lib/kafka/producer.rb in ruby-kafka-0.3.13.beta2

@@ -193,24 +193,27 @@
         create_time,
         key.to_s.bytesize + value.to_s.bytesize
       )
 
       if buffer_size >= @max_buffer_size
-        buffer_overflow topic, "Max buffer size (#{@max_buffer_size} messages) exceeded"
+        buffer_overflow topic,
+          "Cannot produce to #{topic}, max buffer size (#{@max_buffer_size} messages) reached"
       end
 
       if buffer_bytesize + message.bytesize >= @max_buffer_bytesize
-        buffer_overflow topic, "Max buffer bytesize (#{@max_buffer_bytesize} bytes) exceeded"
+        buffer_overflow topic,
+          "Cannot produce to #{topic}, max buffer bytesize (#{@max_buffer_bytesize} bytes) reached"
       end
 
       @target_topics.add(topic)
       @pending_message_queue.write(message)
 
       @instrumenter.instrument("produce_message.producer", {
         value: value,
         key: key,
         topic: topic,
         create_time: create_time,
+        message_size: message.bytesize,
         buffer_size: buffer_size,
         max_buffer_size: @max_buffer_size,
       })
 
       nil