From 95737d9b89bd9b8afa85c12e9aa174fda3ee0982 Mon Sep 17 00:00:00 2001
From: Job Evers <job.evers@udacity.com>
Date: Thu, 22 Jan 2015 17:25:02 -0600
Subject: [PATCH] Add failed_payloads attribute to FailedPayloadsError

---
 kafka/common.py | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/kafka/common.py b/kafka/common.py
index b7bb06c..f40c9fa 100644
--- a/kafka/common.py
+++ b/kafka/common.py
@@ -161,7 +161,9 @@ class KafkaTimeoutError(KafkaError):
 
 
 class FailedPayloadsError(KafkaError):
-    pass
+    def __init__(self, failed_payloads, *args):
+        super(FailedPayloadsError, self).__init__(*args)
+        self.failed_payloads = failed_payloads
 
 
 class ConnectionError(KafkaError):