Skip to content

Commit 1321f98

Browse files
committed
Do not update reconnect backoff when closing w/o error
1 parent 243b55b commit 1321f98

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

kafka/conn.py

+2-1
Original file line numberDiff line numberDiff line change
@@ -934,7 +934,8 @@ def close(self, error=None):
934934
if self.state is ConnectionStates.DISCONNECTED:
935935
return
936936
log.log(logging.ERROR if error else logging.INFO, '%s: Closing connection. %s', self, error or '')
937-
self._update_reconnect_backoff()
937+
if error:
938+
self._update_reconnect_backoff()
938939
self._api_versions_future = None
939940
self._sasl_auth_future = None
940941
self._init_sasl_mechanism()

0 commit comments

Comments
 (0)