《七牛云》专题
-
如何通过由REST api触发的Spring云流优雅地处理Kafka发布失败
我有一个场景，必须通过服务层中RESTAPI的触发器发布多条消息。 此服务还具有db操作（插入、更新）。这里的要求是，如果存在导致publisher无法发布的问题的网络问题，或者当kafka broker不可用时，我们希望回滚包括数据库在内的所有内容，并通过API响应通知用户它失败。 问题1：是否可以通过启用Kafka事务性来实现需求？ 据我所知，默认情况下，同一事务中的数据库将首先提交，然后由K
-
Spring云流的动态目的地-Kafka
我正在开发一个路由器（事件代理）应用程序与Spring云流在Kafka，在功能范式。应用程序从不断输入的主题消耗，映射和过滤消息，然后应该根据一些输入字段将其发送到某个主题（一次只有单个消息，而不是多个结果）。 最好的方法是设置Spring。云流动发送到。输出消息的目标标题？如果是这样，我应该如何为生产者设置绑定？
-
当依赖物有Spring云启动器侦察时，莴苣抛出NPE
我使用spring会话数据redis来管理会话。它将在每次请求之前从redis获取会话数据。但当从redis获取会话时，它会抛出一个NPE。如果我删除SpringCloudStarterSleuth依赖项，它就不会发生。 springboot版本：2.3。8.释放 springcloud版本：霍克斯顿。SR10 以下是例外信息：
-
Spring云流Azure事件中心绑定器中的消息消耗后没有DB提交
我有一个事件侦听器Spring boot应用程序，它执行从Azure事件中心主题读取操作- 我只是遵循了链接eventhubs活页夹示例中的示例。 在@StreamListener注释方法内执行的任何JPA save操作都不会将数据插入DB中。。 非常感谢您的任何提示。。我想我必须对事务同步（KafkaTransactionManager-JPATransactionManager）做些什么，但不
-
Spring云流生产者重试和错误处理
我设置了一个Spring云流Kafka制作人和消费者，有3个Kafka经纪人在运行。我已经设置了min.insync。将副本复制到4，以查看生产者错误处理的工作方式。消息通道。send（发送） 以上是我的生产者配置。虽然retries设置为3，但生产者仍会多次重试。虽然sync设置为true，但发送呼叫会立即发出。虽然定义了错误通道和目标，并且将errorChannelEnabled设置为true
-
Kafka制作人Spring云应用程序不会发布任何内容
我开始将我的spring云应用程序与docker compose文件中托管的kafka和zookeeper连接，它们是连接的，但当我运行应用程序并期望制作人发布消息时，什么也得不到。。。我不知道错误是什么，我遵循以下示例：https://github.com/ihuaylupo/manning-smia/tree/master/chapter10/licensing-service/src/mai
-
Spring云流Kafka活页夹压缩
如何使用Spring Cloud Stream Kafka Binder为生产者启用压缩（例如GZIP）？
-
为什么需要Spring侦探，当Spring云启动器zipkin使用zipkin.brave?
添加只是span-Cloud-starter-zipkin也能够生成spanId和TraceId那么侦察的需要是什么？Spring-云-启动器-拉链实际上自己拉io.zipkin.brave不是侦探。
-
春云侦察3.0.1生成跟踪我正在使用在日志文件中生成和。我可以使用版本。我尝试过使用，但无法使用版本。按照3.0。1文档中，他们已经删除了旧的MDC条目，但是 特雷赛德 我已尝试在zipkin上查看此请求的跟踪，并能够使用traceid和spanid查看它： 有人可以帮助我得到Traceid和spanid在日志文件使用logback/log4j？
-
通过Jetty服务器将Spring云侦探添加到Spring应用程序
我正在尝试将SpringCloudSleuth与使用jetty服务器的现有spring应用程序集成。 我补充说 和 启动应用程序时，我应该如何传递记录器属性、日志模式？现在，它不会读取/resources文件夹下的属性文件，也不会生成traceId或spanId。 大多数示例都使用了Spring Boot。需要帮助来弄清楚如何将此与带有码头服务器的Spring应用程序集成。
-
Spring云流：StreamBridge和事务我希望有一个Spring云流侦听器处理有关其中发送的所有消息的完整事务。或者，即使之后有异常，也会提交函数中使用StreamBridge手动发送的所有消息。 这是我的lib版本： 我的Spring云流形态： 我的测试java代码： 要运行的测试类： 我还添加了TransactionManager： 在最后的这个示例中，我的兔子队列中有： 或者我应该只有两条消息test.other.request.
-
如何修复SynTaxError： wait仅在谷歌云视觉中的异步函数中有效[重复]
我想使用谷歌云视觉API。我复制了代码，但出现以下错误：SyntaxError:await仅在异步函数中有效。 有没有办法解决这个问题？ 非常感谢
-
如何在Firebase的云函数中使HTTP请求异步/等待？
我试图使一个JSON调用异步/等待使用云函数为Firebase。 你知道如何修复下面的代码吗？我的计划失败了。 我的灵感是https://www.valentinog.com/blog/http-requests-node-js-async-await/ 部署误差 函数[setDetails]：部署错误。 异步URL SyntaxError:对象的createScript（vm.js:56:10）
-
分析错误：Firebase云函数-节点中出现意外的令牌selectWinner。JSV10
我无法部署我的云函数，因为我被解析错误击中：意外的令牌selectWner。 我在中更新了解析器选项。eslintrc。json使用ECMAVersion2017，但这不起作用。在进行更改后，我重新启动了文本编辑器（atom），但这也不起作用。 这些函数应该同步处理，但是由于这个错误，我甚至不能得到第一个被调用的函数。 package.json eslintrc.json
-
节点6.14。0 AsyncWait npm包和google云函数->Javascript异步函数
我已经为更新的节点版本编写了代码，我希望将其实现为谷歌云功能（GCF）。现在的问题是GCF只提供节点v6.14.0引擎，不支持异步功能。 我喜欢的解决方案是使用https://www.npmjs.com/package/asyncawait，因为我不需要做重大更改（当我后来希望在新的节点可用时使用本机异步时也同样适用）。然而，我无法运行我的代码，即使我相信我已经正确地遵循了转换中的示例。 如果我按