《玄武云》专题

我正试图在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？

我正在尝试将SpringCloudSleuth与使用jetty服务器的现有spring应用程序集成。 我补充说 和 启动应用程序时，我应该如何传递记录器属性、日志模式？现在，它不会读取/resources文件夹下的属性文件，也不会生成traceId或spanId。 大多数示例都使用了Spring Boot。需要帮助来弄清楚如何将此与带有码头服务器的Spring应用程序集成。

我希望有一个Spring云流侦听器处理有关其中发送的所有消息的完整事务。或者，即使之后有异常，也会提交函数中使用StreamBridge手动发送的所有消息。 这是我的lib版本： 我的Spring云流形态： 我的测试java代码： 要运行的测试类： 我还添加了TransactionManager： 在最后的这个示例中，我的兔子队列中有： 或者我应该只有两条消息test.other.request.

我想使用谷歌云视觉API。我复制了代码，但出现以下错误：SyntaxError:await仅在异步函数中有效。 有没有办法解决这个问题？ 非常感谢