diff options
| author | Dana Powers <dana.powers@rd.io> | 2016-01-03 18:00:03 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2016-01-03 18:00:03 -0800 |
| commit | 95e7a65a8eb64bcb589ced003884424f94b58e8f (patch) | |
| tree | 831b4a066a2984eb7df3c827a8f3b001c5886a76 /kafka/protocol/message.py | |
| parent | ca88921ee77813c83fbef003f6b9d935b9add329 (diff) | |
| download | kafka-python-95e7a65a8eb64bcb589ced003884424f94b58e8f.tar.gz | |
Override Message __hash__ to use _encode_self and not recalc crcs
Diffstat (limited to 'kafka/protocol/message.py')
| -rw-r--r-- | kafka/protocol/message.py | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/kafka/protocol/message.py b/kafka/protocol/message.py index 430ecad..70da5ac 100644 --- a/kafka/protocol/message.py +++ b/kafka/protocol/message.py @@ -68,6 +68,9 @@ class Message(Struct): return MessageSet.decode(raw_bytes, bytes_to_read=len(raw_bytes)) + def __hash__(self): + return hash(self._encode_self(recalc_crc=False)) + class PartialMessage(bytes): def __repr__(self): |