Override Message __hash__ to use _encode_self and not recalc crcs

2016-01-03 18:00:03 -08:00
parent ca88921ee7
commit 95e7a65a8e
1 changed files with 3 additions and 0 deletions
--- 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):