Spring Cloud Stream允许用户使用Spring Integration开发和运行消息传递微服务，并在本地或云中或甚至在Spring Cloud Data Flow上运行它们。只需添加@EnableBinding并将您的应用程序作为Spring Boot应用程序（单个应用程序上下文）运行。您只需要连接到总线的物理代理，如果类路径上有相关的总线实现，则这是自动的。
使用多个绑定器时无法使用@StreamRetryTemplate创建自定义RetryTemplate
我正在使用带有多个绑定器的spring cloud stream。我尝试使用@StreamRetryTemplate创建自定义RetryTemplate。自定义RetryTempalte的Bean正在创建，但没有注入...
我正在为kafka设置架构注册服务器。我已经使用了融合模式注册表，一切都很好，但后来我看到，你可以用更少的麻烦设置一个默认的，弹簧。所以我做了但是我...
如何使用Spring云流访问使用密码保护的融合模式注册表服务器？
我正在使用Spring云流与Aiven的架构注册表一起使用汇编的架构注册表。 Aiven的架构注册表使用密码进行保护。根据这些说明，这两个......
如何在spring-cloud-stream中的kafka流程拓扑中使用交互式查询？
是否可以在Spring Cloud Stream中使用带有@EnableBinding注释的类或使用@StreamListener的方法中的交互式查询（InteractiveQueryService）？我试过实例化......
我有@Component注释的spring组件类，在其中我有字段ConcurrentHashMap映射，它是组件的构造函数中的init，用于spring流监听器：@Component public ...
我有以下组件，用于向broker（kafka）发送消息，并由Spring-cloud的StreamListener接收。现在我需要写测试，我发送消息到嵌入式代理和...
我正在使用spring-cloud-stream在微服务之间进行通信。我在rabbit mq broker中有以下预定义设置。 “first” - >交换绑定到Queue的Topic类型（...
我正在尝试安排在SCDF中启动组合任务，但一直无法找到这样做的方法。我找到的最接近的东西是TriggerTask源和tasklauncher接收模块....
Spring Cloud Stream Reactive，如何为生产者设置路由密钥
Spring Cloud Stream允许我们使用应用程序配置设置路由密钥，例如：cloud.stream：default：contentType：“application / json”rabbit.bindings：output-resync-events：...
使用Spring Cloud Stream为RabbitMQ定义消费者标记
是否可以使用spring cloud stream为rabbitmq绑定定义使用者标记？例如，我绑定到rabbitmq并在管理控制台中看到以下消费者标记：...
我有一个侦听器方法来处理由Spring云流实现的消息，如下所示：@StreamListener（value = MyInterface.INPUT）public void handle Msg（@Payload Foo foo）{// if if（...
场景：我正在使用spring数据启动器应用程序来创建FTP源。代码：@SpringBootApplication @Import（{FtpSourceConfiguration.class，AWSLocalStackConfig.class}）公共类...
Spring Cloud Stream - 覆盖错误处理程序
我有一个多绑定器弹簧云流应用程序，我的实现与在此重复使用RabbitMQ Binder的文档中解释的实现完全相似我打算重试...
我正在尝试Spring Cloud Data Flow，今天我更新到了最新版本，因为我无法创建这个简单的例子，它应该简单地记录AMQP消息。记录......
与此文章类似，我创建了另一个基于涡轮流的应用程序，以从其他应用程序收集hystrix流。 Spring Boot：2.0.4.RELEASE，Spring Cloud：Finchley.SR1应用程序......
Spring Boot微服务@StreamListener在抛出RunTimeException时重试无限时间
我有一个@StreamListener方法，它将执行REST调用。当REST调用返回异常时，@ StreamListener方法将抛出RunTimeException并执行重试。 @StreamListener方法将...
spring cloud stream两个不同组的不同并发设置不起作用
我已经配置了默认并发设置，我有另一个需要不同并发级别的组，但第二个是默认的并发性为1。它工作得很好......
使用kafka-avro-console-consumer消耗spring spring stream kafka发送的avro消息时出错
我尝试使用我本地安装的汇合4.0.0的官方模式 - 注册表 - 汇合示例（使用者/制作者），它可以在发送发送请求时发送“sensor”avro消息并在侦听器中接收，但是...
Spring Integration Kinesis适配器和消费者组
我有一个使用spring-integration-aws版本1.1.0.RELEASE开发的kinesis消费者应用程序。在我的测试中，我在同一个使用者组中运行此应用程序的两个实例并且......
带有Testbinder的KStream - Spring Cloud Stream Kafka
我最近开始研究适用于Kafka的Spring Cloud Stream，并努力让TestBinder与Kstreams合作。这是一个已知的限制，还是我只是忽略了一些东西？这个 ...