diff options
| author | Dana Powers <dana.powers@gmail.com> | 2016-04-05 00:35:13 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2016-04-05 10:22:54 -0700 |
| commit | ee43e3a66a4bdb47a10b99ad71257e051afc81f5 (patch) | |
| tree | cf86076c391a5d44ecddb8adaeb9183ed2eba661 | |
| parent | 145ac227cb7f471467de52c5016ed3727e417911 (diff) | |
| download | kafka-python-ee43e3a66a4bdb47a10b99ad71257e051afc81f5.tar.gz | |
KAFKA-3013: Include topic-partition in exception for expired batches
| -rw-r--r-- | kafka/producer/record_accumulator.py | 5 |
1 files changed, 4 insertions, 1 deletions
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 |