From ee43e3a66a4bdb47a10b99ad71257e051afc81f5 Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Tue, 5 Apr 2016 00:35:13 -0700 Subject: KAFKA-3013: Include topic-partition in exception for expired batches --- kafka/producer/record_accumulator.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) (limited to 'kafka') diff --git a/kafka/producer/record_accumulator.py b/kafka/producer/record_accumulator.py index b3abaa3..8f59afa 100644 --- a/kafka/producer/record_accumulator.py +++ b/kafka/producer/record_accumulator.py @@ -81,7 +81,10 @@ class RecordBatch(object): 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 -- cgit v1.2.1