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