Update kafka.util.crc32 to unsigned everywhere

1 files changed, 2 insertions, 2 deletions

diff --git a/kafka/protocol.py b/kafka/protocol.py
index a9475c3..e5356c5 100644
--- a/kafka/protocol.py
+++ b/kafka/protocol.py
@@ -98,7 +98,7 @@ class KafkaProtocol(object):
             msg += write_int_string(message.key)
             msg += write_int_string(message.value)
             crc = crc32(msg)
-            msg = struct.pack('>i%ds' % len(msg), crc, msg)
+            msg = struct.pack('>I%ds' % len(msg), crc, msg)
         else:
             raise ProtocolError("Unexpected magic number: %d" % message.magic)
         return msg
@@ -148,7 +148,7 @@ class KafkaProtocol(object):
         The offset is actually read from decode_message_set_iter (it is part
         of the MessageSet payload).
         """
-        ((crc, magic, att), cur) = relative_unpack('>iBB', data, 0)
+        ((crc, magic, att), cur) = relative_unpack('>IBB', data, 0)
         if crc != crc32(data[4:]):
             raise ChecksumError("Message checksum failed")