diff options
| author | Dana Powers <dana.powers@rd.io> | 2015-12-31 11:20:01 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2015-12-31 11:20:01 -0800 |
| commit | 61ccbc5f7bd1527096c4609f2e881e6a1075e579 (patch) | |
| tree | 417795cd7bf0873f27aea25c5eb31c32244c06b2 | |
| parent | bc2688e69c46fe6890c2e44990720698475c85ed (diff) | |
| download | kafka-python-61ccbc5f7bd1527096c4609f2e881e6a1075e579.tar.gz | |
Fixup heartbeat config assertion
| -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 |