Spring Cloud Stream允许用户使用Spring Integration开发和运行消息传递微服务，并在本地或云中或甚至在Spring Cloud Data Flow上运行它们。只需添加@EnableBinding并将您的应用程序作为Spring Boot应用程序（单个应用程序上下文）运行。您只需要连接到总线的物理代理，如果类路径上有相关的总线实现，则这是自动的。
使用Function接口创建的Spring云流应用程序无法在Spring云数据流中进行数据通信。
我使用Spring云函数方法传输Flux创建了3个简单的Spring云流应用(SourceProcessorSink)。Source-app。@SpringBootApplication public class SourceApplication { ...
Spring Cloud Hoxton.SR5与最新版本的Spring Cloud Schema Registry（2.2.1.RELEASE）不兼容。
我们的微服务实现目前在Spring Cloud Hoxton.SR4上，我们已经能够成功处理Spring Cloud Stream Kinesis请求（发送Avro消息），同时使用Spring ...
我想对异常使用DLQ，这是application.yml主题已成功创建，但是我在DLQ主题中未收到异常消息spring：cloud：stream：default：...
如何向Spring Cloud Dataflow应用程序添加属性
我是Spring Cloud数据流的新手。我正在编写一个“源”应用程序，但无法弄清楚如何向该应用程序添加属性。我在文档中找不到任何帮助。我遵循了...
是Kafka的新手，并且对多个教程感到非常困惑。设置任何kafka avro是否都需要架构注册表？如何使用spring boot-Kafka项目进行设置。
如何在Spring Cloud Kafka Streams应用程序中执行flatTransform？
我正在尝试在Spring Cloud Kafka Streams应用程序中执行flatTransform。但我不确定将KafkaStreamsStateStore批注确切放置在何处。目前，我收到错误消息：Invalid ...
如何测试Spring Cloud Stream Listener
我有一个使用以下方法调用服务的控制器：东西send（SomeMessage message）{binding.sendSomeMessage（）。send（MessageBuilder.withPayload（message）.build（））; } @StreamListener（...
我正在使用带有Kafka活页夹的Spring Cloud Stream的DLQ功能。当消息处理失败时，该消息将按预期发送到DLQ，但是，我希望能够将消息修改为...
了解Spring Cloud Stream Kafka和Spring重试
我有一个使用Kafka活页夹的Spring Cloud Stream项目，我试图理解并最终定制Cloud Stream使用的RetryTemplate。我没有找到很多有关如何...
Spring Cloud Stream Kafka Streams：下游消息数与发送给该主题的消息总数不匹配
我有一个基于Spring Boot的Spring Cloud Stream Kafka Streams Binder应用程序。它定义了一个拓扑，其中包含以下内容：绿色的数字表示通过...
如何处理Spring cloud流kafka流活页夹中的序列化错误？
我正在使用Spring Cloud Stream Kafka Streams绑定器编写Kafka Streams应用程序。使用者将消息发布到输出主题时，可能会出现诸如序列化错误或...
我有兴趣使用Spring Cloud Stream在我们项目中的某些生产者中使用发布者确认。我曾尝试做一个小的PoC，但是它不起作用。据我所见...
我已阅读到，如果某个使用者接受了一条消息，但未确认在给定的时间范围内已成功处理该消息，那么将向另一个使用者提供相同的消息以保证...
如果在处理步骤期间发生故障，如何使Spring云流Kafka流绑定程序重试处理消息？
我正在使用Spring Cloud Stream开发Kafka Streams。在消息处理应用程序中，可能会产生错误。因此，不应提交和重试该消息...
我目前正在试验一种用例，我们必须先将多个输入消息聚合到一个用例中，然后再将其写入文件系统。为此，我正在尝试使用聚合器模块...
用于大量数据处理的Spring Boot应用程序的Spring Kafka或Kafka流
我正在使用Spring boot，Kafka和QuickFIX / J为银行创建大量JSON数据处理应用程序。这是我第一次使用Kafka，QuickFIX / J和...
[Kafka新手。 Kafka版本：2.3.1我正在尝试使用Spring Cloud从两个主题中使用Kafka消息。除了kafka活页夹和一些简单的配置，例如...
具有扩展绑定属性的Spring Cloud Stream定制活页夹
我正在为Spring Cloud Streams编写自定义活页夹。基本的资料夹已挂接到Spring Cloud Streams中，并且可以正常工作。我现在正在尝试创建扩展的绑定属性。我正在尝试遵循...
如何从已在配置中定义spring.rabbitmq.addresses的服务连接到两个不同的Rabbitmq群集
我们有一些服务，它们共享基本的通用配置以连接到不同的外部系统（DB，Rabbitmq等）和通用设置。我们对rabbitmq拥有的变量之一是spring ....