diff options
| author | Dana Powers <dana.powers@rd.io> | 2016-01-03 18:17:23 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2016-01-03 18:46:09 -0800 |
| commit | 1bcb9f029d7179a23d2e008891cfb9e7f0534d64 (patch) | |
| tree | 67f82fe23c7bfb279a362f7ad6d2ad90223292a7 | |
| parent | b13c92306cf0b115c0aae8d1c50007bbcb1d1107 (diff) | |
| download | kafka-python-1bcb9f029d7179a23d2e008891cfb9e7f0534d64.tar.gz | |
Message value can be None
| -rw-r--r-- | kafka/protocol/message.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/protocol/message.py b/kafka/protocol/message.py index 70da5ac..2648e24 100644 --- a/kafka/protocol/message.py +++ b/kafka/protocol/message.py @@ -22,7 +22,7 @@ class Message(Struct): CODEC_SNAPPY = 0x02 def __init__(self, value, key=None, magic=0, attributes=0, crc=0): - assert isinstance(value, bytes), 'value must be bytes' + assert value is None or isinstance(value, bytes), 'value must be bytes' assert key is None or isinstance(key, bytes), 'key must be bytes' self.crc = crc self.magic = magic |