看了 celery 的文档,在 4.2 版本中,讲到稳定支持的有 RabbitMQ、Redis、Amazon SQS (不了解)、Zookeeper (试验阶段)
http://docs.celeryproject.org/en/master/getting-started/brokers/index.html
没看到有队 kafka 的支持,实际测试了也没成功过,有相关实现的同学么?
1
julyclyde 2019-01-13 16:55:07 +08:00
请勿拿着锤子看啥都像钉子
kafka 是可重复读出的,如果有多个 worker 的话,会导致任务重复执行 |