FailedPayloadsError now only has a single payload; use .payload attribute

.failed_payloads attribute has been removed.

Author: Dana Powers

kafka/common.py

@@ -169,9 +169,9 @@ class KafkaTimeoutError(KafkaError):
 
 
 class FailedPayloadsError(KafkaError):
-    def __init__(self, failed_payloads, *args):
+    def __init__(self, payload, *args):
         super(FailedPayloadsError, self).__init__(*args)
-        self.failed_payloads = failed_payloads
+        self.payload = payload
 
 
 class ConnectionError(KafkaError):

test/test_producer.py

@@ -143,7 +143,7 @@ def test_first_send_failed(self):
         def send_side_effect(reqs, *args, **kwargs):
             if self.client.is_first_time:
                 self.client.is_first_time = False
-                return [FailedPayloadsError(reqs)]
+                return [FailedPayloadsError(req) for req in reqs]
             return []
 
         self.client.send_produce_request.side_effect = send_side_effect
@@ -165,7 +165,7 @@ def test_with_limited_retries(self):
             self.queue.put((TopicAndPartition("test", i), "msg %i" % i, "key %i" % i))
 
         def send_side_effect(reqs, *args, **kwargs):
-            return [FailedPayloadsError(reqs)]
+            return [FailedPayloadsError(req) for req in reqs]
 
         self.client.send_produce_request.side_effect = send_side_effect