search

joowani / kq

Kafka-based Job Queue for Python
http://kq.readthedocs.io
MIT License
572 stars 24 forks source link

Key support #4

Closed shashankmehra closed 7 years ago

shashankmehra commented 7 years ago

Use Kafka's in-order guarantee to support in-order tasks. To process certain tasks in order they were produced, simply enqueue them with the same key. Tasks with different keys or None as key, will be processed by a 'random' partition decided by kafka's default partitioner.

Merging to dev branch instead.

coveralls commented 7 years ago

Coverage Status

Coverage remained the same at 100.0% when pulling 4645ddfc99e2ec01a75de3f3fdc2da513099f5f4 on shashankmehra:key_support into 5f89dd3142709f69eeca73ca7620c3ef8574c2a4 on joowani:dev.