我正在尝试在docker容器中创建一个webapi,它将被运送到openshift示例中。api有一个swagger和一个带有kafka consumer settings参数的httppost方法来启动consumer。api在本地运行时没有问题,但是当我在openshift上发布它时,它在大约30秒后返回504。我想要的是一个循环请求,它可以在不中断的情况下听取消费者的意见。所以我的问题是我的方法是正确的还是我应该用另一种方法?怎么会这样?
一些日志:info:microsoft.aspnetcore.hosting.internal.webhost[1]请求启动http/1.1 posthttp:///startkafkaconsumer 应用程序/json补丁+json 175 info: Microsoft.AspNetCore.Mvc.Internal.ControllerActionInvoker[1] Route matched with {action = "StartKafkaConsumer", controller = "NotificationManager"}. Executing action xManager.API.Controllers.xxManagerController.StartKafkaConsumer (xManager.API) info: Microsoft.AspNetCore.Mvc.Internal.ControllerActionInvoker[1] Executing action method xxManager.API.Controllers.xxManagerController.StartKafkaConsumer (xManager.API) with arguments (xManager.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); }
提前谢谢!
暂无答案!
目前还没有任何答案,快来回答吧!