clear changelogReader on thread shutdown

LGouellec · Nov 19, 2024 · d0f0c2c · d0f0c2c
1 parent ab6df11
commit d0f0c2c
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/core/Processors/StreamThread.cs b/core/Processors/StreamThread.cs
@@ -566,6 +566,8 @@ private void CompleteShutdown()
                     consumer.Close();
                     consumer.Dispose();
 
+                    changelogReader.Clear();
+
                     streamMetricsRegistry.RemoveThreadSensors(threadId);
                     log.LogInformation($"{logPrefix}Shutdown complete");
                     IsDisposable = true;