diff options
Diffstat (limited to 'kafka/util.py')
| -rw-r--r-- | kafka/util.py | 4 |
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) |