We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent f0a57a6 commit 356f493Copy full SHA for 356f493
kafka/record/_crc32c.py
@@ -138,8 +138,12 @@ def crc(data):
138
139
140
if __name__ == "__main__":
141
+ import six
142
import sys
143
# TODO remove the pylint disable once pylint fixes
144
# https://github.com/PyCQA/pylint/issues/2571
- data = sys.stdin.read() # pylint: disable=assignment-from-no-return
145
+ if six.PY2:
146
+ data = sys.stdin.read() # pylint: disable=assignment-from-no-return
147
+ else:
148
+ data = sys.stdin.buffer.read() # pylint: disable=assignment-from-no-return
149
print(hex(crc(data)))
0 commit comments