spring-cloud-aws相关内容

Spring Aws Kinesis Binder ProvisionedThroughputExceededException,同时在批处理模式下消费消息

我正在使用批处理模式从 kinesis 流中提取记录.我们正在使用 spring aws kinesis binder. 大多数时候我们无法从流中提取消息.只有某些时候我们能够从流中提取消息. 我的配置如下所示 我的配置 弹簧:云:溪流:运动:粘合剂:锁:租期:30读取容量:1写入容量:1检查点:读取容量:1写入容量:1绑定:InStreamGroupOne:消费者:liste ..

Spring Aws Kinesis Binder ProvisionedThroughputExceededException,同时在批处理模式下使用消息

我正在使用批处理模式从 kinesis 流中提取记录.我们正在使用 spring aws kinesis binder. 大多数时候我们无法从流中提取消息.只有有时我们能够从流中提取消息. 我的配置如下 我的配置 弹簧:云:溪流:运动:粘合剂:锁:租期:30读取容量:1写入容量:1检查点:读取容量:1写入容量:1绑定:内流组一:消费者:侦听器模式:批处理idleBetweenP ..

IdleBetween 池未按指定提取消息

我正在以批处理模式消费消息.我想每 250 毫秒从流中提取 8 条消息. 弹簧:云:流:运动:绑定:输入:消费者:侦听器模式:批处理idleBetweenPolls: 250记录限制:8绑定:输入:组:我的组目的地:流内容类型:应用程序/json 我已将大约 100 条消息推送到流中,然后我启动了消费者. 根据配置,我应该每 250 毫秒提取一次消息.但是轮询器不会每 250 毫秒拉取一 ..

Spring Boot - Spring Cloud AWS:找不到区域

我有一个 Spring Boot、Spring Cloud AWS 服务,用于从 AWS SQS 队列接收消息.在我自己的个人 AWS 账户服务中一切正常,区域设置为“us-east-1",但是当切换到 AWS GovCloud 区域“us-gov-east-1"时,收到错误消息“The区域“us-gov-east-1"不是有效区域".追踪与提取真正旧版本的 aws-java-sdk-core-1 ..
发布时间:2021-08-20 19:49:26 其他开发

防止 spring-cloud-aws-messaging 尝试停止队列

我在 Spring Boot 项目中使用 spring-cloud-aws-messaging. 我在 AWS 中手动创建了 SQS 队列. 它的用法如下: @SqsListener("${sqs.name.incoming}")公共无效听(字符串消息){...} 它工作正常.但是当我在 IDE 中停止我的应用程序时,或者当 Spring Boot 测试完成时,它会尝试停止队列.它无法 ..

如何使用Spring Cloud AWS从S3删除文件?

我无法在Spring AWS Cloud中找到任何API或文档来从S3存储桶中删除对象.有人可以让我知道怎么做吗? 文档只是谈论阅读内容使用ResourceLoader. 我现在看到的唯一选项是显式注入AmazonS3并调用deleteObject. 解决方案 Spring的Resource API不支持操作的整个生命周期.两个主要接口是Resource和WritableRes ..

在批处理模式下使用消息时,Spring Aws Kinesis Binder ProvisionedThroughputExceededException

我正在使用批处理模式从kinesis流中提取记录。 在大多数情况下,我们无法从流中提取消息。 我的配置如下所示 我的配置 spring: 云: 流: 运动: 活页夹: 锁: 租约时间:30 读容量:1 write容量:1 检查点:$ b​​ $ b read容量:1 writeCapacity:1 绑定: InStreamGroupOne: 使用者: 侦 ..

带有Spring-cloud-aws和cloudwatch指标的Springboot

我想开始在Springboot应用程序中使用指标,我还想将其发布到我的Amazon cloudwatch中 我知道,借助Springboot,我们可以激活spring-actuator来提供内存指标并将其发布到/metrics端点. 我偶然发现了Spring-cloud,它似乎有一些库可以定期将这些指标发布到Cloudwatch,但是我不知道如何设置它们?绝对有0个使用它的例子. ..