Spring-云-流-活页夹-运动AWS
我们如何使用Spring-Cloud-stream-binder-kinesis建立两个AWS kinesis连接？
第一个连接：Spring应用程序和AWS kinesis流在同一个AWS账户中。
第二个连接：其他AWS运动流位于不同的AWS帐户中。
从spring应用程序到不同AWS帐户中的两个不同运动流是否可能有两个不同的连接？如果是，我们如何实施？
共有1个答案
请参见连接到多个系统。
默认情况下，绑定共享应用程序的Spring Boot自动配置，以便创建类路径上找到的每个绑定的一个实例。如果应用程序应连接到同一类型的多个代理，则可以指定多个绑定器配置，每个配置具有不同的环境设置。
-
如何使用Spring Cloud Stream Kafka Binder为生产者启用压缩（例如GZIP）？
-
我有一个使用kafka活页夹的spring cloud stream应用程序，它可以消费和发送消息。在应用程序中，我使用重试策略配置自定义错误处理程序，并将不可重试的异常添加到处理程序中。配置示例： 但是我看到，如果异常抛出，比应用程序重试处理消息3次。预期行为-如果App. MyCustomException.class抛出，将不会重复消费消息。如何为Spring云流kafka绑定应用程序配置重
-
我正在尝试通过SCSt频道构建并获取KTable。但这并不奏效。输入KTable没有数据，但如果我尝试查看KSTream聚合（toStream（）），我可以看到一些数据。我明白了，KTable是不可查询的，它没有可查询的名称。 类别： 绑定: application.yml：
-
我有一个以Functional方法实现的Spring云流应用程序。应用程序使用来自多个Kafka主题的事件，将输入规范化为输出模式（始终是相同的模式），并发布到Kafka。我不使用Kafka流，因为不需要加入/充实/状态。 我想通过控制输入主题来允许灵活的部署：您可以从所有主题消费，也可以从单个主题消费。我的方法是为每种类型声明专用函数，并为每种函数声明专用绑定。问题是绑定器（有一个）将所有传入消
-
版本:Spring Boot: 1.4.2 .发布春云Deps:布里克斯顿。SR7 这是我的申请。处理器应用程序的属性。 当我启动此应用程序时，将按预期创建事件交换，并将其绑定到名为：events exchange的队列。eventconsumers组（也可以）。但routingKey始终为“#”。我已经尝试了从各种文档中找到的所有选项。我在这里遗漏了什么吗？ 我希望这个应用程序只订阅某些消息（我