diff options
| author | Dana Powers <dana.powers@gmail.com> | 2016-07-17 14:39:27 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2016-07-17 17:54:06 -0700 |
| commit | 3a7802d51c3a34f1efafb97b80deceab98ec8b09 (patch) | |
| tree | 792ac17bcbb0f37fddd42a6594b4406fba9f7a67 /kafka/coordinator/heartbeat.py | |
| parent | 436b2b20117ea60f9cdcad1f6f8ad46cb439c1ed (diff) | |
| download | kafka-python-3a7802d51c3a34f1efafb97b80deceab98ec8b09.tar.gz | |
Add base coordinator metrics
Diffstat (limited to 'kafka/coordinator/heartbeat.py')
| -rw-r--r-- | kafka/coordinator/heartbeat.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/kafka/coordinator/heartbeat.py b/kafka/coordinator/heartbeat.py index 1cd9863..648cb1f 100644 --- a/kafka/coordinator/heartbeat.py +++ b/kafka/coordinator/heartbeat.py @@ -20,8 +20,8 @@ class Heartbeat(object): self.interval = self.config['heartbeat_interval_ms'] / 1000.0 self.timeout = self.config['session_timeout_ms'] / 1000.0 - self.last_send = 0 - self.last_receive = 0 + self.last_send = -1 * float('inf') + self.last_receive = -1 * float('inf') self.last_reset = time.time() def sent_heartbeat(self): |