Я реализовал потребитель Kafka, используя .net core 2.1 с Confluent.Kafka SDK (C #). Функция опроса настроена на запуск в течение 10 минут, а код развертывается как лямбда-функция AWS, которая запускается каждые 1 час при событии наблюдения за облаком. Как изящно отключить потребителя, если в теме нет сообщений? Любые предложения
Спасибо