从dotnet核心消费Kafka Topic将进入无限循环。
consumer.Subscribe("my topic name"); while (true){ var kfReslt = consumer.Consume() }
pftdvrlh1#
你应该使用CancellationToken来停止消费。下面是一个在后台线程上使用Kafka主题的控制台应用的示例:
CancellationToken
using CancellationTokenSource cancellationTokenSource = new CancellationTokenSource(); Task task = Task.Run(() => { consumer.Subscribe("my topic name"); while (!cancellationToken.IsCancellationRequested) { var kfReslt = consumer.Consume(); //... } }); Console.WriteLine("Press any key to stop consuming..."); Console.ReadKey(); cancellationTokenSource.Cancel();
1条答案
按热度按时间pftdvrlh1#
你应该使用
CancellationToken
来停止消费。下面是一个在后台线程上使用Kafka主题的控制台应用的示例: