diff options
| author | Dana Powers <dana.powers@rd.io> | 2015-06-10 12:08:02 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2015-06-10 12:08:02 -0700 |
| commit | 942c693c23996a3430c82fff8714fecb821a2b9d (patch) | |
| tree | 47ffa4cbfd8be50282ed3314ec2013103f01aa01 /kafka | |
| parent | 8984141aefecedd260485047760c70fdc171c74f (diff) | |
| download | kafka-python-942c693c23996a3430c82fff8714fecb821a2b9d.tar.gz | |
Add error type to SimpleConsumer error logging
Diffstat (limited to 'kafka')
| -rw-r--r-- | kafka/consumer/simple.py | 13 |
1 files changed, 8 insertions, 5 deletions
diff --git a/kafka/consumer/simple.py b/kafka/consumer/simple.py index e4233ff..aa49fca 100644 --- a/kafka/consumer/simple.py +++ b/kafka/consumer/simple.py @@ -344,23 +344,26 @@ class SimpleConsumer(Consumer): try: check_error(resp) except UnknownTopicOrPartitionError: + log.error('UnknownTopicOrPartitionError for %s:%d', + resp.topic, resp.partition) self.client.reset_topic_metadata(resp.topic) raise except NotLeaderForPartitionError: + log.error('NotLeaderForPartitionError for %s:%d', + resp.topic, resp.partition) self.client.reset_topic_metadata(resp.topic) continue except OffsetOutOfRangeError: - log.warning("OffsetOutOfRangeError for %s - %d. " - "Resetting partition offset...", + log.warning('OffsetOutOfRangeError for %s:%d. ' + 'Resetting partition offset...', resp.topic, resp.partition) self.reset_partition_offset(resp.partition) # Retry this partition retry_partitions[resp.partition] = partitions[resp.partition] continue except FailedPayloadsError as e: - log.warning("Failed payloads of %s" - "Resetting partition offset...", - e.payload) + log.warning('FailedPayloadsError for %s:%d', + e.payload.topic, e.payload.partition) # Retry this partition retry_partitions[e.payload.partition] = partitions[e.payload.partition] continue |