adding random bytes to key

Author: sibiryakov

frontera/contrib/messagebus/kafka/transport.py

@@ -3,6 +3,13 @@
 import hashlib
 from cachetools import LRUCache
 from msgpack import Packer, unpackb
+from random import randint
+from six import MAXSIZE
+from struct import pack
+
+
+def random_bytes():
+    return pack("L", randint(0, MAXSIZE))
 
 
 class FramedTransport(object):
@@ -37,6 +44,7 @@ def write(self, key, msg):
             seg_count = int(ceil(length / float(seg_size)))
             h = hashlib.sha1()
             h.update(msg)
+            h.update(random_bytes())
             msg_key = h.digest()
             for seg_id in range(seg_count):
                 seg_msg = msg[seg_id * seg_size: (seg_id + 1) * seg_size]