diff --git a/ConsoleApp2/HostedServices/OutputService.cs b/ConsoleApp2/HostedServices/OutputService.cs
index b4598e3..a6f2ccd 100644
--- a/ConsoleApp2/HostedServices/OutputService.cs
+++ b/ConsoleApp2/HostedServices/OutputService.cs
@@ -40,7 +40,6 @@ public class OutputService : IOutputService
     public async Task ExecuteAsync(CancellationToken cancellationToken)
     {
         _logger.LogInformation("***** Mysql output service started *****");
-        var count = 0;
         _taskManager.CreateTasks(async () =>
         {
             var records = new List<DataRecord>();
@@ -48,12 +47,10 @@ public class OutputService : IOutputService
             {
                 if (!_consumerQueue.TryDequeue(out var record)) continue;
                 records.Add(record);
-                count++;
                 //_logger.LogInformation(@"*****OutputCount: {count} *****",count);
                 if (records.Count >= _outputOptions.Value.FlushCount)
                 {
                     await FlushAsync(records);
-                    _context.AddOutput(count);
                     records.Clear();
                 }
                 if (_context.GetExceptions().Count>0)