diff --git a/kafka/producer/kafka.py b/kafka/producer/kafka.py
index dd1cc508c..4b5ea45b6 100644
--- a/kafka/producer/kafka.py
+++ b/kafka/producer/kafka.py
@@ -615,7 +615,7 @@ def send(self, topic, value=None, key=None, headers=None, partition=None, timest
             # for API exceptions return them in the future,
             # for other exceptions raise directly
         except Errors.BrokerResponseError as e:
-            log.debug("Exception occurred during message send: %s", e)
+            log.error("Exception occurred during message send: %s", e)
             return FutureRecordMetadata(
                 FutureProduceResult(TopicPartition(topic, partition)),
                 -1, None, None,
diff --git a/kafka/producer/sender.py b/kafka/producer/sender.py
index 35688d3f1..c99157e0c 100644
--- a/kafka/producer/sender.py
+++ b/kafka/producer/sender.py
@@ -181,7 +181,7 @@ def add_topic(self, topic):
             self.wakeup()
 
     def _failed_produce(self, batches, node_id, error):
-        log.debug("Error sending produce request to node %d: %s", node_id, error) # trace
+        log.error("Error sending produce request to node %d: %s", node_id, error) # trace
         for batch in batches:
             self._complete_batch(batch, error, -1, None)