问题标签 [spring-integration-aws]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
spring - 尝试使用 spring-integration-aws S3StreamingMessageSource 轮询 S3 时的 NPE
我正在尝试按照此处的示例（在流式入站通道适配器下）使用 S3StreamMessageSource 轮询 S3 对象存储：https ://github.com/spring-projects/spring-integration-aws/tree/v1.1.0.RELEASE
但是每次我的应用程序启动时，都会抛出一个 NPE：
当我逐步检查抛出异常的位置时，它位于S3FileInfo.getPermissions中的代码部分 ，我看到UnsupportedOperationException “使用 [AmazonS3.getObjectAcl()] 获取权限。”
我需要做什么来解决这个问题？我正在使用 Spring Boot 1.5.9.RELEASE、spring-integration-aws 1.1.0.RELEASE、spring-integration-core 5.0.0.RELEASE
amazon-sqs - spring 集成 sqs 出站网关
我尝试将https://github.com/3pillarlabs/spring-integration-aws项目用于 SQS 出站网关，但最终出现错误：
我知道官方的 spring 集成支持 SQS 出站适配器。我正在寻找一个网关，在将消息发布到 SQS 后，我可以继续执行更多操作。你们中的任何人都知道这些方面的任何事情吗？
提前致谢！
spring-integration - 在 Spring Cloud Aws Kinesis Stream 中实现自定义错误消息处理程序
我已经编写了监听 Kinesis 流的 Spring Cloud Stream 应用程序
跨渠道的消息流
我计划编写跨这些渠道的错误处理。目前我明确地捕捉到错误并发送到不同的渠道。我不想捕获和修改有效负载，而是想实现通用异常处理程序
粘合剂
配置
变压器
并在路由器路由到不同的通道错误
错误处理
我们能否实现所有这些通道的通用异常处理程序。
目前我只处理Transformer中的错误，但是如果Router或以后的通道出现异常，那么这也需要手动处理
任何有助于更好地处理错误的见解
spring-integration - 在 Spring Intehration 中读取 Aws Kinesis Streams 时全局处理特定于通道的错误
我正在收听 aws kinesis 流，并在全局范围内启用了错误处理，并且特定于通道，如下所示。
应用程序 Yml
我已经编写了全局错误通道的处理程序，如下所示
错误处理程序
我的频道特定错误频道的配置
消息监听器和通道错误监听器
活页夹接口
该错误既不是由全局 errorChannel 处理的，也不是由我的通道特定的错误通道处理的
我错过了什么吗。
异常日志
有人可以帮忙吗
更新 我尝试使用以下代码但无法捕获错误。我尝试了 Stream Listener 和服务激活器。如果我做错了什么，你能帮帮我吗？
应用程序 Yml
班级
并且在任何地方都没有发现错误
spring-integration - 上下文中的并发消费者到弹簧集成
在 Spring 集成应用程序中，我使用并发消费者一次消费和处理多条消息。在我的应用程序中，我将所有 bean 配置为一个单例。我假设我是否要通过使用并发消费者的并行化处理，多条消息输入到相同的集成组件中。它会导致两个对象之间的数据冲突吗？
java - 以固定的时间间隔从输入流中消费消息
我正在使用流侦听器来使用来自 amazon kinesis 流的消息。
- 是否可以实现一个侦听器，它每 10 分钟从输入流中获取一次所有消息
- 当有消费者群体时，它将如何表现。消费者组中的所有容器是否获得不同的消息列表。
我试过了，@Poller但它没有任何输入通道。
对此的任何帮助都会很棒。
spring-integration - 消息上的特殊字符消耗 spring-integration-aws
我们从 spring-integration 应用程序将消息发送到 kinesis 流，但是在通过 kinesis binder 应用程序的 @StreamListener 使用消息时，我们得到了特殊字符，例如“�� t foo”。请在代码片段下方找到并告诉我是否还有其他需要考虑的事项？
向 Kinesis 发送消息
接收消息
spring-integration - 从 kinesis 收到的消息中的 Spring 云流特殊字符
当我使用来自 kinesis 流的消息时。我得到一些带有标题等的垃圾字符
应用 yml
我在侦听器和 errorChannel 都得到了带有垃圾字符的输出
我正在尝试在 errorChannel 中提取原始消息。这是转换字节消息的正确方法吗？
spring-cloud-stream - Spring Cloud aws流，消息被消费者组中的多个实例消费
我用 spring cloud aws binder 编写了一个示例应用程序
代码
应用程序.yml
我已经在多个端口上启动了应用程序
当我将消息发布到流时，大多数时候不止一个实例正在使用消息。
例如我发送了消息 {"22":"11"}，这已被 8083 和 8084 消费
申请信息：8084
申请信息：8083
理想情况下，组中只有一个消费者可以处理消息。我在这里错过了什么吗？
spring-boot - spring boot 和 spring 集成 aws kinesis 错误
我已经使用 kinesis 设置了 spring boot、spring-integration-aws 并在应用程序启动时不断出现以下错误。
我不知道我的配置是否正确？
我的 maven pom.xml 正确吗？
如果 spring.io 可以为 spring-integration 和 aws-kinisis 提供端到端的示例应用程序，那就太好了。
任何帮助赞赏消除此错误。它不断地重复。
提前谢谢你。