From eac51e9c68c50f15962b6c785ede92cb3d512a17 Mon Sep 17 00:00:00 2001 From: David Arthur Date: Fri, 1 Mar 2013 15:12:21 -0500 Subject: Integration tests passing --- kafka/util.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'kafka/util.py') 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) -- cgit v1.2.1