replace kafka with celery for couchpulse