《光锥云》专题

我在cloud firestore中有2个集合，希望通过我的产品“userBids”的一个字段使用这两个集合，我正在使用文档参考： Ürünler（产品） 问题我想从我的产品模型中的“userBids”字段联系我的用户，但下面出现了错误； 类“DocumentReference”没有实例方法“[]”。 接收方：“DocumentReference”的实例 试着打电话：） 那么，我如何才能在Flat

我一直试图用. onUpdate（）触发器推送通知，但它不起作用。我不知道出了什么问题，因为我在文档上找到的任何东西都毫无用处，这是我第一次和ode.js.一起工作 当任何产品使用Firebase Cloud Functions（在Firebase实时数据库中）更新时，我想通知用户（使用Firebase消息传递），这是在提交订单之后，并且要求产品库存是 集合的结构如下：产品（集合）-

假设我正在创建一个PWA（渐进式网络应用程序），用户可以在其中添加产品。这些产品的价格从0.01 EUR到1.00 EUR不等。我使用条纹支付。条纹订单对象不支持动态价格，动态传递，没有任何引用（一种外键）。要接受订单，Stripe需要引用SKU。在我的例子中，这个SKU将是产品价格的变化。这意味着，为了涵盖所有变化，我需要100个SKU，从1（0.01欧元）到100（1,00欧元）。因此，对于在

我正试图在Google App Engine上从Quarkus连接到PostgreSQL数据库。为此，必须提供额外的JDBC属性“socketFactory”和“cloudSqlInstance”。但我不知道如何在应用程序中指定这些。属性。 根据https://quarkus.io/guides/datasource，有一个属性quarkus.datasource.jdbc.additional。

我正在尝试用spring cloud stream实现spring cloud契约。我有一个使用StreamBridge的制作人 方法sendMessage（）是从rest控制器调用的。 我的合同是这样的： 当我运行测试时，会调用triggerCreateOrganization（）方法，并在日志中看到日志消息“生产组织到主题”。 我在生成的测试的基类上有@AutoConfigureMessage

我有一个StreamListener，我想用新的功能模型和消费者替换它 我厌倦了某些事情。下面是示例代码。我将日志消息添加到另一个队列中进行测试。然后我抛出一个异常以触发回滚。不幸的是，消息是排队的，即使它们在方法完成之前不在那里（我使用制动点对此进行了测试）。尽管有错误，但事务似乎是自动提交的。 配置：

我有一个场景，必须通过服务层中RESTAPI的触发器发布多条消息。 此服务还具有db操作（插入、更新）。这里的要求是，如果存在导致publisher无法发布的问题的网络问题，或者当kafka broker不可用时，我们希望回滚包括数据库在内的所有内容，并通过API响应通知用户它失败。 问题1：是否可以通过启用Kafka事务性来实现需求？ 据我所知，默认情况下，同一事务中的数据库将首先提交，然后由K

我正在开发一个路由器（事件代理）应用程序与Spring云流在Kafka，在功能范式。应用程序从不断输入的主题消耗，映射和过滤消息，然后应该根据一些输入字段将其发送到某个主题（一次只有单个消息，而不是多个结果）。 最好的方法是设置Spring。云流动发送到。输出消息的目标标题？如果是这样，我应该如何为生产者设置绑定？

我使用spring会话数据redis来管理会话。它将在每次请求之前从redis获取会话数据。但当从redis获取会话时，它会抛出一个NPE。如果我删除SpringCloudStarterSleuth依赖项，它就不会发生。 springboot版本：2.3。8.释放 springcloud版本：霍克斯顿。SR10 以下是例外信息：

我有一个事件侦听器Spring boot应用程序，它执行从Azure事件中心主题读取操作- 我只是遵循了链接eventhubs活页夹示例中的示例。 在@StreamListener注释方法内执行的任何JPA save操作都不会将数据插入DB中。。 非常感谢您的任何提示。。我想我必须对事务同步（KafkaTransactionManager-JPATransactionManager）做些什么，但不

我设置了一个Spring云流Kafka制作人和消费者，有3个Kafka经纪人在运行。我已经设置了min.insync。将副本复制到4，以查看生产者错误处理的工作方式。消息通道。send（发送） 以上是我的生产者配置。虽然retries设置为3，但生产者仍会多次重试。虽然sync设置为true，但发送呼叫会立即发出。虽然定义了错误通道和目标，并且将errorChannelEnabled设置为true

我开始将我的spring云应用程序与docker compose文件中托管的kafka和zookeeper连接，它们是连接的，但当我运行应用程序并期望制作人发布消息时，什么也得不到。。。我不知道错误是什么，我遵循以下示例：https://github.com/ihuaylupo/manning-smia/tree/master/chapter10/licensing-service/src/mai

如何使用Spring Cloud Stream Kafka Binder为生产者启用压缩（例如GZIP）？

添加只是span-Cloud-starter-zipkin也能够生成spanId和TraceId那么侦察的需要是什么？Spring-云-启动器-拉链实际上自己拉io.zipkin.brave不是侦探。

我正在使用在日志文件中生成和。我可以使用版本。我尝试过使用，但无法使用版本。按照3.0。1文档中，他们已经删除了旧的MDC条目，但是 特雷赛德 我已尝试在zipkin上查看此请求的跟踪，并能够使用traceid和spanid查看它： 有人可以帮助我得到Traceid和spanid在日志文件使用logback/log4j？