One possible solution is to manually delete the consuming segment and let the controller create a new one during real-time segment validation. But this scenario is not covered in the PinotLLCRealtimeSegmentManager.ensureAllPartitionsConsuming() yet.