diff options
| -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 |