KAFKA-3013: Include topic-partition in exception for expired batches

dpkp · dpkp · commit ee43e3a66a4b · 2016-04-05T10:22:54.000-07:00
diff --git a/kafka/producer/record_accumulator.py b/kafka/producer/record_accumulator.py
@@ -81,7 +81,10 @@ def maybe_expire(self, request_timeout_ms, linger_ms):
         if ((self.records.is_full() and request_timeout_ms < since_append_ms)
             or (request_timeout_ms < (since_append_ms + linger_ms))):
             self.records.close()
-            self.done(-1, Errors.KafkaTimeoutError('Batch Expired'))
+            self.done(-1, Errors.KafkaTimeoutError(
+                "Batch containing %s record(s) expired due to timeout while"
+                " requesting metadata from brokers for %s", self.record_count,
+                self.topic_partition))
             return True
         return False
 
