We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent a27e521 commit bb3827eCopy full SHA for bb3827e
kafka/util.py
@@ -16,7 +16,7 @@ def write_int_string(s):
16
def write_short_string(s):
17
if s is None:
18
return struct.pack('>h', -1)
19
- elif len(s) > 32767 and sys.version < (2,7):
+ elif len(s) > 32767 and sys.version < (2, 7):
20
# Python 2.6 issues a deprecation warning instead of a struct error
21
raise struct.error(len(s))
22
else:
@@ -117,4 +117,5 @@ def stop(self):
117
118
self.active.set()
119
self.thread.join(self.t + 1)
120
+ # noinspection PyAttributeOutsideInit
121
self.timer = None
0 commit comments