spring-cloud相关内容

如何配置自定义 Spring Cloud AWS SimpleMessageListenerContainerFactory 以便它继续与 @SqsListener 一起工作

我正在尝试让 SpringCloud AWS SQS 与自定义 SimpleMessageListenerContainerFactory 一起工作,以便我可以设置超时和最大消息数.如果没有使用 @SqsListener 注释的自定义 SimpleMessageListenerContainerFactory 方法,可以很好地拾取 SQS 中的消息.但是当我尝试配置自定义 SimpleMessag ..
发布时间:2021-11-27 11:14:03 其他开发

zookeeper 与 spring 云配置服务器有什么区别?

zookeeper 和 spring 云配置服务器有什么区别?它们都将配置存储在服务器中并使它们可供客户端使用. 什么时候应该使用一个而不是另一个? 解决方案 zookeeper 和 spring 云配置服务器有什么区别? 使用 Spring Cloud Config Server,您可以集中管理所有环境中应用程序的外部属性.配置服务器上的概念与 Spring Enviro ..
发布时间:2021-11-14 23:59:34 其他开发

当控制去捕获块时如何停止发送到 kafka 主题功能 kafka spring

你能告诉我如何停止发送到我的第三个 kafka 主题,当控件到达 catch 块时,当前消息被发送到错误主题以及在正常情况下应该发送到的主题加工.代码片段如下: @Component公共类 Abc {私有最终 StreamBridge streamBridge;公共 Abc (StreamBridge streamBridge)this.streamBridge = 流桥;@豆角,扁豆公共函数 ..
发布时间:2021-11-12 03:34:25 其他开发

Spring Cloud Streams 有条件地将数据转发到 Kafka 主题

我正在尝试根据一些评估将数据发送到不同的主题.我正在使用 SPring CLoud Streams 和 Kafka 如何有条件地转发kafka主题.需要在我专门评论的地方插入SCS-kafka相关代码. 谢谢. @EnableBinding(Sink.class)公共类 SampleSink {私有最终记录器记录器 = LoggerFactory.getLogger(this.ge ..
发布时间:2021-11-12 03:09:30 其他开发

如何使用嵌入在 spring 云流中的 kafka 创建单元测试

很抱歉这个问题太笼统了,但有人有一些关于如何使用嵌入式 kafka 执行生产者和消费者测试的教程或指南.我尝试了几个,但有几个版本的依赖项,但没有一个真正有效 =/ 我使用的是 Spring Cloud Stream kafka. 解决方案 我们一般推荐使用 Test Binder 在测试中但如果你想使用嵌入式 kafka 服务器,它可以完成... 将此添加到您的 POM... ..
发布时间:2021-11-12 01:57:01 其他开发

如何使用 Spring Cloud Stream Kafka 和每个服务的数据库实现微服务事件驱动架构

我正在尝试实现一个事件驱动架构来处理分布式事务.每个服务都有自己的数据库,并使用 Kafka 发送消息通知其他微服务有关操作. 示例: 订购服务 ------->|卡夫卡|------->支付服务||订单 MariaDB DB 付款 MariaDB 数据库 订单收到订单请求.它必须将新订单存储在其数据库中并发布一条消息,以便支付服务意识到它必须为该项目收费: 私人订单业务订单业务 ..
发布时间:2021-11-12 01:54:39 其他开发

当控制去捕获块时如何停止发送到 kafka 主题功能 kafka spring

你能告诉我如何停止发送到我的第三个 kafka 主题,当控件到达 catch 块时,当前消息被发送到错误主题以及在正常情况下应该发送到的主题加工.代码片段如下: @Component公共类 Abc {私有最终 StreamBridge streamBridge;公共 Abc (StreamBridge streamBridge)this.streamBridge = 流桥;@豆角,扁豆公共函数 ..
发布时间:2021-11-12 01:50:10 其他开发

Spring Coud Sleuth 导致 ActiveMQ/JMS 消息头丢失

版本: SpringBoot:2.3.12.RELEASE SpringCloud:Hoxton.SR12 SpringCloud Starter Sleuth:3.0.3 骆驼:3.4.6 我想将 Sleuth 添加到一个现在使用 ActiveMQ 的预先存在的项目中,以前它是在使用 JMS.当我这样做时,来自 ActiceMQ 消息的值被阻止/删除(一个是“文件名",它是 S ..
发布时间:2021-11-11 23:07:17 其他开发

Spring Cloud - SQS - 此 wsdl 版本不存在指定的队列

我正在尝试让 Spring Cloud 使用自动配置来处理消息传递. 我的属性文件包含: cloud.aws.credentials.accessKey=xxxxxxxxxxcloud.aws.credentials.secretKey=xxxxxxxxxxcloud.aws.region.static=us-west-2 我的配置类如下: @EnableSqs@ComponentSc ..
发布时间:2021-11-10 22:51:06 其他开发

使用 SpringBootRequestHandler 在函数内部访问 AWS Lambda 上下文?

我需要为我的 lambda 函数访问 AWS Lambda 的上下文.我正在使用 SpringBootRequestHandler 来接收请求,它应该调用一个实现 Function 接口的类.下面是两个类的代码示例: public class A extends SpringBootRequestHandler{@覆盖公共对象句柄请求(S3Event 事件,上下文上下文){返回 super.ha ..
发布时间:2021-10-27 19:18:52 其他开发

Spring Coud Sleuth 导致 ActiveMQ/JMS 消息头丢失

版本: SpringBoot:2.3.12.RELEASE SpringCloud:Hoxton.SR12 SpringCloud Starter Sleuth:3.0.3 骆驼:3.4.6 我想将 Sleuth 添加到一个现在使用 ActiveMQ 的预先存在的项目中,以前它是在使用 JMS.当我这样做时,来自 ActiceMQ 消息的值被阻止/删除(一个是“文件名",它是 S ..
发布时间:2021-10-26 16:32:48 其他开发

Spring Cloud Stream 默认自定义消息头

当从方法返回值生成消息时,有没有办法配置默认的Message标头: @Publisher(channel = "theChannelname")公共 MyObject someMethod(Object param) {...返回我的对象​​;} 或 @SendTo("theChannelname")公共 MyObject someMethod(Object param) {...返回我的对 ..
发布时间:2021-08-20 20:11:45 其他开发

使用 Spring Boot 1.5.1 在 Camden.SR5 中配置 Spring Cloud Stream

首先,感谢 Spring 团队为推动这项工作所做的所有工作! 现在Camden.SR5正式版了,我有一些问题在使用Spring Boot 1.5.1时如何正确配置spring cloud stream kafka binder. Spring Boot 1.5.1 对 kafka 进行了自动配置,而这些配置选项似乎与 Spring Cloud Stream kafka binder 中 ..
发布时间:2021-08-20 20:11:42 其他开发

LoadBalancing Spring 云数据流服务器

在 spring 云数据流中,根据我的理解,每个流都是一个微服务,但数据流服务器不是.我说得对吗? Spring Cloud Dataflow(SCDF) 服务器是否可以有多个实例?如何对数据流服务器进行负载平衡?我打算在 AWS 中部署它.官方文档没有提到有关数据流服务器负载平衡的任何内容.如果可能的话,仪表板、外壳如何工作? 解决方案 SCDF-server 是一个常规的 Spr ..
发布时间:2021-08-20 20:09:29 其他开发

将 Spring Cloud Contract 验证发布到 Pact broker

是否可以将 Spring Cloud Contract Producer 验证发布给 Pact broker? 解决方案 您必须将 DSL 转换为 Pact 文件,然后推送这些文件.所以从技术上讲这是可能的. 更新:我们在文档中描述了如何做到这一点 - https://cloud.spring.io/spring-cloud-contract/reference/html/howto ..
发布时间:2021-08-20 20:07:46 其他开发

在 PCF 上使用 Spring Cloud Data Flow 在 PCF 上注册应用程序时需要帮助,Spring Cloud Data Flow 也在 PCF 上

1) 我已经使用 cf push -p abcdef.jar sinkapp 在 PCF 上注册了一个接收器应用程序.一切顺利 2) 现在我的 SCDF 服务器也在 PCF 上 如何使用位于同一 PCF、同一组织、同一空间上的数据流在 SCDF 服务器上注册 sinkapp.因为我不知道我应该参考什么来注册它?我正在寻找可以从数据流 shell 提供给 SCDF 的命令. 谢谢. ..
发布时间:2021-08-20 20:07:43 其他开发

Spring Boot 自动配置 spring.factories

我正在按照说明操作 此处 提供自定义 RestTemplate. 我已经创建了 spring.factories 文件并验证它在META-INF 目录或 JAR. 我已经按照描述创建了类. 我在我的 中添加了一些日志语句 CustomConfigServiceBootstrapConfiguration 并且它们在我运行应用程序后不会出现. 似乎 spring.fact ..
发布时间:2021-08-20 20:07:40 其他开发

Hystrix.stream 和 management.context

设置 management.context-path =/admin 并使用 @EnableCircuitBreaker 使 Hystrix 端点/admin/hystrix.stream 当使用 Turbine 来聚合指标时,这会成为一个问题 instanceserver:port/hystrix.stream 通过 Eureka 发现实例时 有什么建议吗? 解决 ..
发布时间:2021-08-20 20:07:37 其他开发