diff options
| author | Dana Powers <dana.powers@rd.io> | 2016-01-03 17:12:15 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2016-01-03 17:12:15 -0800 |
| commit | 8f15262c794b16ad330194f062091d0b42ac5a41 (patch) | |
| tree | dd3bf8893643a4a6df4a4e07f6b42f101c524563 /kafka/protocol/message.py | |
| parent | d73f26d57fe307897b1a6d000ef971764b7f79ee (diff) | |
| download | kafka-python-8f15262c794b16ad330194f062091d0b42ac5a41.tar.gz | |
Assert Message value and (optional) key are bytes
Diffstat (limited to 'kafka/protocol/message.py')
| -rw-r--r-- | kafka/protocol/message.py | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/kafka/protocol/message.py b/kafka/protocol/message.py index f893912..430ecad 100644 --- a/kafka/protocol/message.py +++ b/kafka/protocol/message.py @@ -22,6 +22,8 @@ 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 key is None or isinstance(key, bytes), 'key must be bytes' self.crc = crc self.magic = magic self.attributes = attributes |