regenerate
fun regenerate(afterId: String, limit: Int, batchExecutionPolicy: BatchExecutionPolicy): Flux<AggregateId>
Regenerates the snapshots of up to limit aggregates after afterId, batchExecutionPolicy bounding how many run at once; emits each aggregate it went through. A failed aggregate fails the batch with a BatchTaskException naming it.