remove old abstract worker
Merge branch 'kafka' into stage

* kafka:
  remove old abstract worker