polish new kafka based dispatcher/worker