diff options
| author | Dana Powers <dana.powers@rd.io> | 2015-06-09 23:18:03 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2015-06-10 07:53:30 -0700 |
| commit | 8984141aefecedd260485047760c70fdc171c74f (patch) | |
| tree | 45e746fa6cc77d9b9d15296bd1fa6f1cbabd24f0 | |
| parent | ded2ac7d321bab02c2b9fb3d8b03a60d6b9a5f84 (diff) | |
| download | kafka-python-8984141aefecedd260485047760c70fdc171c74f.tar.gz | |
Log response error type in async producer
| -rw-r--r-- | kafka/producer/base.py | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/kafka/producer/base.py b/kafka/producer/base.py index 49090bd..3c826cd 100644 --- a/kafka/producer/base.py +++ b/kafka/producer/base.py @@ -166,8 +166,9 @@ def _send_upstream(queue, client, codec, batch_time, batch_size, if error_cls: _handle_error(error_cls, orig_req) - log.error('Error sending ProduceRequest (#%d of %d) to %s:%d ' - 'with msgs %s', i + 1, len(requests), + log.error('%s sending ProduceRequest (#%d of %d) ' + 'to %s:%d with msgs %s', + error_cls.__name__, (i + 1), len(requests), orig_req.topic, orig_req.partition, orig_req.messages if log_messages_on_error else hash(orig_req.messages)) |