@@ -18,7 +18,7 @@ namespace TelpoPush.WanJiaAn.Worker | |||||
while (!stoppingToken.IsCancellationRequested) | while (!stoppingToken.IsCancellationRequested) | ||||
{ | { | ||||
await _kafkaSubscribe.SubscribeAsync(); | await _kafkaSubscribe.SubscribeAsync(); | ||||
await Task.Delay(1000000, stoppingToken); | |||||
await Task.Delay(1000, stoppingToken); | |||||
} | } | ||||
} | } | ||||
} | } | ||||