Integration tests passing

1 files changed, 2 insertions, 2 deletions

diff --git a/kafka/util.py b/kafka/util.py
index 509c5b8..715fb28 100644
--- a/kafka/util.py
+++ b/kafka/util.py
@@ -4,13 +4,13 @@ import struct
 
 def write_int_string(s):
     if s is None:
-        return struct.pack('>i', 0) # TODO change this to -1 when KAFKA-771 is accepted
+        return struct.pack('>i', -1)
     else:
         return struct.pack('>i%ds' % len(s), len(s), s)
 
 def write_short_string(s):
     if s is None:
-        return struct.pack('>h', 0) # TODO change this to -1 when KAFKA-771 is accepted
+        return struct.pack('>h', -1)
     else:
         return struct.pack('>h%ds' % len(s), len(s), s)