lib/deimos/utils/db_producer.rb in deimos-kafka-1.0.0.pre.beta20 vs lib/deimos/utils/db_producer.rb in deimos-kafka-1.0.0.pre.beta21

@@ -100,9 +100,12 @@
           if batch_size < 10
             batch_size = 1
           else
             batch_size /= 10
           end
+          if self.class.producer.respond_to?(:sync_producer_shutdown) # Phobos 1.8.3
+            self.class.producer.sync_producer_shutdown
+          end
           retry
         end
       end
     end
   end