diff --git a/splitter-cli/JobProcessor.cs b/splitter-cli/JobProcessor.cs
index a5c5e2e..ac59206 100644
--- a/splitter-cli/JobProcessor.cs
+++ b/splitter-cli/JobProcessor.cs
@@ -79,7 +79,8 @@ public class JobProcessor(ILogger logger) : LoggingBase(logger, 0), IJobProcesso
         }
         else
         {
-            processorFactory = i => new PassthroughSplitter(i, _logger);
+            //processorFactory = i => new PassthroughSplitter(i, _logger);
+            processorFactory = i => new ReencodeSplitter(i, _logger);
         }
 
         var segmentsToUse = predefinedSegments;
diff --git a/splitter-cli/ReencodeSplitter.cs b/splitter-cli/ReencodeSplitter.cs
new file mode 100644
index 0000000..31d0055
--- /dev/null
+++ b/splitter-cli/ReencodeSplitter.cs
@@ -0,0 +1,105 @@
+using System.Diagnostics;
+using System.Globalization;
+
+namespace splitter;
+
+public sealed class ReencodeSplitter : LoggingBase, ISegmentProcessor
+{
+    private sealed class State : IFrameProcessingState
+    {
+        public Process? EncodeProcess { get; set; }
+
+        public string InputFile { get; }
+        public string OutputFile { get; }
+        public double Start { get; }
+        public double Length { get; }
+        public string[] Passthrough { get; }
+
+        public State(SingleTask job)
+        {
+            InputFile = job.Job.InputFile;
+            OutputFile = job.OutputFileName;
+            Start = job.SegmentStart;
+            Length = job.SegmentLength;
+            Passthrough = job.Job.Passthrough;
+        }
+    }
+
+    public ReencodeSplitter(int segmentNo, ILogger logger)
+        : base(logger, segmentNo)
+    {
+    }
+
+    public IFrameProcessingState InitSegment(SingleTask job, CancellationToken token)
+    {
+        var state = new State(job);
+        state.EncodeProcess = StartEncode(job);
+        return state;
+    }
+
+    public FrameProcessingResult GetNextProcessedFrame(IFrameProcessingState processorState, CancellationToken token)
+    {
+        return new FrameProcessingResult(null, [], null);
+    }
+
+    public void FinishSegment(IFrameProcessingState processorState)
+    {
+        var state = (State)processorState;
+
+        try
+        {
+            if (state.EncodeProcess != null && !state.EncodeProcess.HasExited)
+                state.EncodeProcess.WaitForExit();
+        }
+        catch { }
+    }
+
+    public async Task ProcessSegment(
+        SingleTask job,
+        Action<FrameProcessingResult>? onFrameProcessed,
+        CancellationToken token)
+    {
+        var state = (State)InitSegment(job, token);
+
+        var p = state.EncodeProcess;
+        if (p != null)
+            await p.WaitForExitAsync(token);
+
+        FinishSegment(state);
+
+        ClearProgress(job.OutputFileName);
+
+        if (p != null && p.ExitCode != 0)
+            LogError($"Segment {job.OutputFileName} FFmpeg reencode failed");
+        else
+            LogInfo($"Segment {job.OutputFileName} reencode completed");
+    }
+
+    private Process StartEncode(SingleTask job)
+    {
+        var inputFile  = job.Job.InputFile;
+        var outputFile = job.OutputFileName;
+        var start      = job.SegmentStart;
+        var length     = job.SegmentLength;
+
+        var args =
+            $"-ss {start.ToString(CultureInfo.InvariantCulture)} " +
+            $"-i \"{inputFile}\" " +
+            $"-t {length.ToString(CultureInfo.InvariantCulture)} " +
+            "-c:v h264_nvenc -preset p4 -b:v 8M -pix_fmt yuv420p " +
+            "-c:a aac -b:a 192k " +
+            $"{string.Join(" ", job.Job.Passthrough)} " +
+            $"\"{outputFile}\" -y";
+
+        var psi = new ProcessStartInfo
+        {
+            FileName              = "ffmpeg",
+            Arguments             = args,
+            RedirectStandardError = true,
+            UseShellExecute       = false,
+            CreateNoWindow        = true
+        };
+
+        return Process.Start(psi) ?? throw new Exception("Failed to start ffmpeg reencode.");
+    }
+}