search

alm0ra / mockafka-py

Mockafka-py is a Python library designed for in-memory mocking of Kafka.[aiokafka - confluence-kafka-python]
https://mockafka-py.readthedocs.io
MIT License
44 stars 11 forks source link

Remove extra random.shuffle in consumer #165

Closed BrianMowrey closed 5 days ago

BrianMowrey commented 1 week ago

Removed an extra random.shuffle to fix a bug where if you are subscribe to more than 1 topic, and produce to just 1 topic, at some point you will receive None for a message because it checks the same topic twice for a new message. Also added a test around the issue.