A migrator for event streams