diff options
| author | Dana Powers <dana.powers@gmail.com> | 2019-12-28 16:33:33 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2019-12-28 16:33:33 -0800 |
| commit | 9ac3d7adf403b19daf58e33ef2f7a1582190b411 (patch) | |
| tree | 8e22a52f78ef055864591c8616e685a48e61985c | |
| parent | 2ed01e96abd8e2b412aa5228131d531e91c50f76 (diff) | |
| download | kafka-python-issue-1943-coordinator-node-not-ready-debug.tar.gz | |
Log retriable coordinator NodeNotReady, TooManyInFlightRequests as debug not errorissue-1943-coordinator-node-not-ready-debug
| -rw-r--r-- | kafka/coordinator/base.py | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/kafka/coordinator/base.py b/kafka/coordinator/base.py index d91f3ea..b0e236a 100644 --- a/kafka/coordinator/base.py +++ b/kafka/coordinator/base.py @@ -489,13 +489,16 @@ class BaseCoordinator(object): 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): |