我编写了一个Firebase云函数,可以通过REST API访问该函数。代码如下所示。 我需要做的是,当用户通过“Web服务URL”从前端提交一些值时。 1)我需要将这些数据保存在Firebase实时数据库中。 2.)我参考了网上的几个教程,不明白在下面的代码中做了什么。
我正在使用微服务,如前端、弹性4j api网关,其中一个是用户微服务,每个服务都在heroku中的单独应用程序中运行。 当从前端调用api网关服务应用程序的url时,我使用feign或rest模板登录时收到413个太大的请求异常 请告诉我根本原因。
我正在尝试将spring云网关与kubernetes服务发现结合使用。下面是我正在使用的设置 建筑格拉德尔 application.yml 演示应用程序。Java语言 Spring云网关无法将请求重定向到其他服务。正在打印的日志是 2019-10-13 18:29:38.303TRACE 1---[or-超文本传输协议-epolp-2]o. s. c. g. f. Weght计算器WebFilte
有一个带有Spring-Boot1.5的微服务,它使用假动作与其他服务通信,还有spring-cloud-starter-zipkin,它通过假动作包装所有调用,并将跟踪发送到zipkin服务器。问题是我不想包装所有的电话并跟踪它们,只有几个最重要的做到这一点。我如何从跟踪中排除一些带有假动作的调用(方法),或者驱逐一些整个假动作的客户端(接口)?
Spring Cloud Sleuth跟踪头是否像这里描述的RabbitMq和Kafka那样被注入到Spring Cloud Stream Kinesis消息中?我们有一个REST控制器,它在处理POST请求之后,但在向客户机发送响应之前,向Kinesis发送一个Avro消息,该消息使用Spring Cloud Stream Kinesis总结事务。我想确保在REST控制器中启动的跟踪id被传播到
我正在尝试将StreamsUncaughtExceptionHandler添加到我的Kafka流处理器。该处理器使用Kafka函数编写。我查看了Artem Bilan提供的将StreamsUncaughtExceptionHandler包括到我的服务中的建议,但我的异常从未被它捕获/处理。 配置Bean: 自定义异常处理程序: 流处理功能: 我希望UnCaughtExceptionHandler处
我已经使用Spring云流启动了一个小型微服务。 我只有两个流绑定,如下所示: 我用Serenity开发了组件测试,我将通道注入到我想要发送测试消息的地方: 哪里: 只是定义为字符串常量: 组件测试模块导入依赖项: 我发送的信息如下: 快乐流工作正常。但是,我想在侦听器无法处理消息时测试错误流。 这是一个监听器的例子: 从try/catch引发异常时,错误由服务激活器处理: 在没有Spring-C
一段时间以来,我一直试图让Spring Cloud Stream与Kafka Streams一起使用,我的项目使用嵌入式kafka进行Kafka DSL测试,我使用这个存储库作为我的测试实现的基础(它本身就是这个问题的测试用例)。 我在这里制作了一个存储库来演示这一点。 基本上,当使用“Processor.class”的“DemoApplicationTest.ExampleAppWorking.
Spring Cloud Kafka Streams与Spring Cloud Stream、Spring Cloud Function、Spring AMQP和Spring for Apache Kafka有什么区别?
我在这个网站上用docker compose启动了Spring云数据流。 https://dataflow.spring.io/docs/installation/local/docker/ 我创建了3个应用程序,源,处理器 我跑了 当我运行docker compose-f时/docker编写。yml-f/docker创作普罗米修斯。yml,所有我的容器都按照docker compose中的指定启
我正在尝试在Spring云数据流中配置DLQ。下面是流定义以及我如何部署它 在自定义转换处理器代码中,我已经提到过 这意味着若消息包含错误,那个么RunTimeException和我想在DLQ中捕获这些消息。但当我运行代码时,似乎没有得到任何名为test tran的Kafka DL队列。 我是否需要设置更多属性来启用DLQ,还是需要更改代码中的某些内容以正确使用DLQ。 自定义转换代码 Trans
我有一个简单的SCDF流,如下所示: http--端口=12346 | mvmn转换|文件--名称=tmp。txt--目录=/tmp mvmn变换是一个简单的自定义变压器,如下所示: 这很好用。 但我读到,Spring云函数应该允许我实现这样的应用程序,而无需指定绑定和转换器注释,所以我将其更改为: 现在我有一个问题-Spring云函数显然忽略了SCDF源和目标主题名称,而创建了主题和。 SCDF
有没有办法允许(Spring Cloud Stream)应用程序在融合云中自动创建所需的主题? 到目前为止,我不得不手动创建它们,当您考虑还必须设置变更日志主题时,这很容易出错。
我正在使用ConFluent托管的Kafka集群和Schema注册表服务。我可以管理连接汇合云kafka集群,将以下属性添加到生产者配置(Scala) 但是不能连接到汇合云模式注册表。汇合云模式注册表提供了访问的键和秘密,但我不知道如何设置键和秘密。是否有任何配置设置用于访问汇合云模式注册表。
我有一个使用Spring cloud stream和Kafka Streams活页夹的项目。对于流的输出,我使用的是Avro,Serde由Confluent提供(