This repository was archived by the owner on Jun 2, 2025. It is now read-only.

Description
Steps to reproduce:
- Run a simulation in multi-engine mode with, say, 2 engines.
- Let the simulation finish. Orchestrator and engines will terminate.
- Start another multi-engine simulation with 3 or 4 engines (> 2)
- The new engines will pick up the old simulation request and complain that no work was found for engines3 and 4.
Cause: Since we're adding new consumers (engines), Kafka delivers the older messages to the engines.
Possible fix: Let the orchestrator delete the simulation requests after the simulation finishes.