Fixup heartbeat config assertion

2015-12-31 11:20:01 -08:00
parent bc2688e69c
commit 61ccbc5f7b
1 changed files with 1 additions and 1 deletions
--- 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