lib/kafka/async_producer.rb in ruby-kafka-0.3.7 vs lib/kafka/async_producer.rb in ruby-kafka-0.3.8

@@ -209,11 +209,11 @@
         retry
       end
 
       def deliver_messages
         @producer.deliver_messages
-      rescue DeliveryFailed
-        # Delivery failed.
+      rescue DeliveryFailed, ConnectionError
+        # Failed to deliver messages -- nothing to do but try again later.
       end
 
       def threshold_reached?
         @delivery_threshold > 0 &&
           @producer.buffer_size >= @delivery_threshold