diff options
| -rw-r--r-- | kafka/coordinator/abstract.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/coordinator/abstract.py b/kafka/coordinator/abstract.py index 1713433..10df9a5 100644 --- a/kafka/coordinator/abstract.py +++ b/kafka/coordinator/abstract.py @@ -574,7 +574,7 @@ class HeartbeatTask(object): def _handle_heartbeat_success(self, v): log.debug("Received successful heartbeat") - self.request_in_flight = False + self._request_in_flight = False self._heartbeat.received_heartbeat() ttl = self._heartbeat.ttl() self._client.schedule(self, time.time() + ttl) |