Always log broker errors in producer.send (#2478)

Author: dpkp

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,

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)