From 95e7a65a8eb64bcb589ced003884424f94b58e8f Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Sun, 3 Jan 2016 18:00:03 -0800 Subject: [PATCH] Override Message __hash__ to use _encode_self and not recalc crcs --- kafka/protocol/message.py | 3 +++ 1 file changed, 3 insertions(+) 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):