Merge pull request #486 from jonsource/feature/log_undelivered_as_error

Allow user to decide whether log undelivered messages as warnings or errors
Parsely · Mar 14, 2016 · 2b2b2ac · 2b2b2ac
2 parents 5b2d0a1 + f14e776
commit 2b2b2ac
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pykafka/producer.py b/pykafka/producer.py
@@ -433,7 +433,7 @@ def mark_as_delivered(message_batch):
                 for msg in mset.messages:
                     if (non_recoverable or msg.produce_attempt >= self._max_retries):
                         self._delivery_reports.put(msg, exc)
-                        log.info("Message not delivered!! %r" % exc)
+                        log.error("Message not delivered!! %r" % exc)
                     else:
                         msg.produce_attempt += 1
                         self._produce(msg)