replace kafka with celery