diff options
Diffstat (limited to 'kafka/coordinator/heartbeat.py')
| -rw-r--r-- | kafka/coordinator/heartbeat.py | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/kafka/coordinator/heartbeat.py b/kafka/coordinator/heartbeat.py index 41ba025..9a28f5e 100644 --- a/kafka/coordinator/heartbeat.py +++ b/kafka/coordinator/heartbeat.py @@ -16,9 +16,9 @@ class Heartbeat(object): if key in configs: self.config[key] = configs[key] - if self.config['heartbeat_interval_ms'] > self.config['session_timeout_ms']: - raise Errors.IllegalArgumentError("Heartbeat interval must be set" - " lower than the session timeout") + assert (self.config['heartbeat_interval_ms'] + <= self.config['session_timeout_ms'], + 'Heartbeat interval must be lower than the session timeout') self.interval = self.config['heartbeat_interval_ms'] / 1000.0 self.timeout = self.config['session_timeout_ms'] / 1000.0 |