Log retriable coordinator NodeNotReady, TooManyInFlightRequests as debug not error (dpkp#1975)

dpkp · web-flow · commit 41d9f1c032f8 · 2019-12-29T15:59:08.000-08:00
diff --git a/kafka/coordinator/base.py b/kafka/coordinator/base.py
@@ -489,13 +489,16 @@ def _send_join_group_request(self):
         return future
 
     def _failed_request(self, node_id, request, future, error):
-        log.error('Error sending %s to node %s [%s]',
-                  request.__class__.__name__, node_id, error)
         # Marking coordinator dead
         # unless the error is caused by internal client pipelining
         if not isinstance(error, (Errors.NodeNotReadyError,
                                   Errors.TooManyInFlightRequests)):
+            log.error('Error sending %s to node %s [%s]',
+                      request.__class__.__name__, node_id, error)
             self.coordinator_dead(error)
+        else:
+            log.debug('Error sending %s to node %s [%s]',
+                      request.__class__.__name__, node_id, error)
         future.failure(error)
 
     def _handle_join_group_response(self, future, send_time, response):
