lib/kafka/producer.rb in ruby-kafka-0.3.13.beta3 vs lib/kafka/producer.rb in ruby-kafka-0.3.13.beta4

@@ -358,10 +358,13 @@
           failed_messages << message
         end
       end
 
       if failed_messages.any?
-        @logger.error "Failed to assign partitions to #{failed_messages.count} messages"
+        failed_messages.group_by(&:topic).each do |topic, messages|
+          @logger.error "Failed to assign partitions to #{messages.count} messages in #{topic}"
+        end
+
         @cluster.mark_as_stale!
       end
 
       @pending_message_queue.replace(failed_messages)
     end