修改

ConsoleApp2/HostedServices/TransformService.cs

@@ -63,7 +63,7 @@ public class TransformService : ITransformService
                 record = replaceRecord;
             }
             _consumerQueue.Enqueue(record);
-            _context.AddTransform();
+             _context.AddTransform();
             //数据增加
             var addRecords=_options.Value.RecordAdd?.Invoke(record);
             if(addRecords != null&& addRecords.Count>0)
@@ -74,6 +74,7 @@ public class TransformService : ITransformService
                     _context.AddTransform();
                 }
             }
+           
         }
 
         _context.CompleteTransform();

ConsoleApp2/Services/MySqlDestination.cs

@@ -61,7 +61,7 @@ public class MySqlDestination : IDisposable, IAsyncDisposable
             {
                 cmd.CommandText = insertSql;
                 await cmd.ExecuteNonQueryAsync();
-                _logger.LogInformation(@"do insert completed!size:{Length}", cmd.CommandText.Length);
+                
             }
             _recordCache.Clear();
         }