Веб-API C # Dotnet Core 2.1 и OpenShift - запуск потребителя Kafka с запросом http - PullRequest
0 голосов
/ 22 октября 2018

Я пытаюсь создать веб-API в контейнере Docker, который будет отправлен в экземпляр OpenShift.В API есть swagger и метод http post с параметрами настройки потребителя Kafka для запуска потребителя.API запускается локально без проблем, но когда я развертываю его в OpenShift, он возвращает 504 примерно через 30 секунд.То, что я хочу, - это циклический запрос, который слушает потребителя без прерывания.Итак, мой вопрос - правильный ли мой подход или я должен сделать это по-другому?Таким образом, как?

Некоторый журнал: info: Microsoft.AspNetCore.Hosting.Internal.WebHost [1] Запрос запуска HTTP / 1.1 POST http://xxxxxx/StartKafkaConsumer application / json-patch + json 175

info: Microsoft.AspNetCore.Mvc.Internal.ControllerActionInvoker[1] Route matched with {action = "StartKafkaConsumer", controller = "NotificationManager"}. Executing action xxxxManager.API.Controllers.xxxxxManagerController.StartKafkaConsumer (xxxxManager.API) info: Microsoft.AspNetCore.Mvc.Internal.ControllerActionInvoker[1] Executing action method xxxxxManager.API.Controllers.xxxxxManagerController.StartKafkaConsumer (xxxxManager.API) with arguments (xxxxManager.EventListeners.Kafka.DTO.KafkaInputConfigDTO) - Validation state: Valid

А: warn: Microsoft.AspNetCore.HttpsPolicy.HttpsRedirectionMiddleware[3] Failed to determine the https port for redirect.

Действие контроллера: [HttpPost("[action]")] public async Task<string> StartKafkaConsumer([FromBody] KafkaInputConfigDTO kafkaInputConfigDTO) { return await _kafkaService.StartKafkaConsumer(kafkaInputConfigDTO); }

Заранее спасибо!

...