-
Notifications
You must be signed in to change notification settings - Fork 1.4k
Closed
Description
Murmur2Partitioner fails if given bytearray keys due to confusion between "key" and "data" vars:
Traceback (most recent call last):
[...]
File "/usr/home/obj/.local/lib/python3.4/site-packages/kafka/producer/keyed.py", line 42, in send_messages
partition = self._next_partition(topic, key)
File "/usr/home/obj/.local/lib/python3.4/site-packages/kafka/producer/keyed.py", line 38, in _next_partition
return partitioner.partition(key)
File "/usr/home/obj/.local/lib/python3.4/site-packages/kafka/partitioner/hashed.py", line 15, in partition
idx = (murmur2(key) & 0x7fffffff) % len(partitions)
File "/usr/home/obj/.local/lib/python3.4/site-packages/kafka/partitioner/hashed.py", line 55, in murmur2
length = len(data)
UnboundLocalError: local variable 'data' referenced before assignment
Metadata
Metadata
Assignees
Labels
No labels