lib/kafka/async_producer.rb in ruby-kafka-0.7.0.alpha4 vs lib/kafka/async_producer.rb in ruby-kafka-0.7.0.beta1

@@ -239,11 +239,13 @@
         retry
       end
 
       def deliver_messages
         @producer.deliver_messages
-      rescue DeliveryFailed, ConnectionError
-        # Failed to deliver messages -- nothing to do but try again later.
+      rescue DeliveryFailed, ConnectionError => e
+        # Failed to deliver messages -- nothing to do but log and try again later.
+        @logger.error("Failed to asynchronously deliver messages: #{e.message}")
+        @instrumenter.instrument("error.async_producer", { error: e })
       end
 
       def threshold_reached?
         @delivery_threshold > 0 &&
           @producer.buffer_size >= @delivery_threshold