Run replication streamers on workers.