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

@@ -151,14 +151,14 @@
       thread.abort_on_exception = true
       thread
     end
 
     def buffer_overflow(topic)
-      @instrumenter.instrument("buffer_overflow.producer", {
+      @instrumenter.instrument("buffer_overflow.async_producer", {
         topic: topic,
       })
 
-      @logger.error "Buffer overflow: failed to enqueue message for #{topic}"
+      @logger.error "Cannot produce message to #{topic}, max queue size (#{@max_queue_size}) reached"
 
       raise BufferOverflow
     end
 
     class Timer