decode ids in EquivalenceUpdatingWorker
Merge branch 'kafka' into stage

* kafka:
  decode ids in EquivalenceUpdatingWorker