Handle updated kafka messages for the storage replayer

---

Migrated from T3882 (view on Phabricator)