c#dotnet core 2.1 web api和openshift-使用http请求启动kafka使用者

jfewjypa  于 2021-06-06  发布在  Kafka
关注(0)|答案(0)|浏览(259)

我正在尝试在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); } 提前谢谢!

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题