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

@@ -318,9 +318,11 @@
           break
         end
       end
 
       unless @pending_message_queue.empty?
+        # Mark the cluster as stale in order to force a cluster metadata refresh.
+        @cluster.mark_as_stale!
         raise DeliveryFailed, "Failed to assign partitions to #{@pending_message_queue.size} messages"
       end
 
       unless @buffer.empty?
         partitions = @buffer.map {|topic, partition, _| "#{topic}/#{partition}" }.join(", ")