diff options
| -rw-r--r-- | kafka/coordinator/heartbeat.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/coordinator/heartbeat.py b/kafka/coordinator/heartbeat.py index 9a28f5e..4ddcf09 100644 --- a/kafka/coordinator/heartbeat.py +++ b/kafka/coordinator/heartbeat.py @@ -17,7 +17,7 @@ class Heartbeat(object): self.config[key] = configs[key] assert (self.config['heartbeat_interval_ms'] - <= self.config['session_timeout_ms'], + <= self.config['session_timeout_ms']), ( 'Heartbeat interval must be lower than the session timeout') self.interval = self.config['heartbeat_interval_ms'] / 1000.0 |