Spring Cloud Stream允许用户使用Spring Integration开发和运行消息传递微服务，并在本地或云中或甚至在Spring Cloud Data Flow上运行它们。只需添加@EnableBinding并将您的应用程序作为Spring Boot应用程序（单个应用程序上下文）运行。您只需要连接到总线的物理代理，如果类路径上有相关的总线实现，则这是自动的。
Spring Cloud Data Flow Server application.properties将被忽略
只是试用Spring Cloud Stream和SCDF，看起来很简单（就像Spring一样）。然而，偶然发现了什么。我有application.properties，它有以下条目。这个 ...
绑定交换以通过Spring cloud stream与rabbitmq binder交换
我正在寻找一种通过Spring云流将RabbitMQ交换绑定到另一个的方法。我知道我可以通过设置producer.requiredGroups属性将队列绑定到交换：spring.cloud ....
Spring-Cloud-Stream-Kafka Custom Health检查不起作用
我在我的spring-boot（消费者）应用程序中使用spring-cloud-stream-kafka。应用程序的运行状况不准确，即使应用程序无法连接到Kafka（Kafka经纪人已关闭），也“UP”。我读过了 ...
如何在Spring启动应用程序中配置KafKaBinderHealthIndicator
我正在尝试在spring boot app中为kafka添加运行状况指示器，但状态不会出现在/ health端点上。我也可以毫无问题地添加其他健康指标。我需要一些特别的......
我正在使用此处的代码开发自定义入门应用程序，因为我想向其添加TcpSSLContextSupport。我已经设法做到了，它在我的本地SCDF服务器上运行良好，但现在我想......
用于Cloud Foundry v1.4.x的Spring Cloud数据流（SCDF）服务器为消息传输配置RabbitMQ服务磁贴部署的Spring云数据流有一个可以生成的处理器......
Spring Cloud Stream会产生不必要的复杂Kafka拓扑，为什么？
我有一个KStream应用程序，包含一堆KStream，连接和其他操作。我启用了logging.level.org.springframework.kafka.config = debug以验证正在生成的拓扑并且...
2位kafka消费者使用不同的SSL配置从2个不同的主题中读取
我正在编写一个Spring启动应用程序，它将使用2个不同的主题并处理该消息。这两个主题托管在不同的群集上，并具有不同的SSL配置。我想要 ...
我们使用Spring云流与Kafka 2.0.1并利用InteractiveQueryService从商店获取数据。聚合数据后，有4个商店在磁盘上保留数据。代码 ...
我需要测试一个包含标题的消息，所以我需要使用MessageBuilder，但我无法序列化。我尝试在生产者道具上添加序列化设置，但它不起作用。能够 ...
春云流和卡夫卡。添加以下依赖项后，将显示此错误。 （如果我注释掉@EnableBinding（Source.class），一切正常。）
Spring Cloud Stream Listener不会暂停/等待Integration Testing Code中的消息
我有一个应用程序通过Spring Cloud Stream连接到RabbitMQ，它完全可以工作。对于Integration测试用例，我试图使用该示例 - https：//github.com/piomin/sample -...
我使用spring kinesis binder在批处理模式下使用消息有时我无法使用来自流的消息。这不是一直没有发生[ShardConsumer {...的记录
Spring Cloud Stream Kafka Stream在加入后不写入目标主题
这是我的应用程序，它只是从客户主题（输入绑定）获取对KStream的引用，而从订单主题（订单绑定）获取另一个。然后它从客户主题创建一个KTable ...
我们使用spring cloud来提供异步任务。我想知道是否有任何方法可以扩展@StreamListener设置的监听器？目标是在一个应用程序实例中拥有多个工作程序。 ...
Spring Kinesis Binder快速填充堆空间导致频繁的GC刷新并且正在减慢消息处理过程
我的应用程序正在消耗一个流，然后在三个流上推送消息Binder：public interface MyBinder {@Input（“input1”）SubscribableChannel input1（）; @Output（“输出1” ......
Spring Cloud Stream中BindingServiceConfiguration.inputBindingLifecycle（）方法的用途是什么？
我想知道在Spring Cloud Stream（对于Kafka）中使用BindingServiceConfiguration.inputBindingLifecycle（）方法，以及这种方法可能有用的业务场景吗？
我正在使用春云流。我有两个频道。一个是使用kafka cluster1，一个是使用cluster2。配置就像。 spring.cloud.stream.default-binder = kafka spring.cloud.stream.binders.kafka.type = ...
我有基于Spring Cloud Stream构建的微服务。测试团队需要为这些服务创建集成测试。什么是最佳做法？根据以下示例，Sink / Source / Processor ...
spring cloud stream file source app - 子目录下的已处理文件和轮询文件的历史记录
我正在管道开始时使用Spring Cloud Stream File Source应用程序构建数据管道。我需要一些帮助来解决一些缺少的功能我的文件源应用程序（基于组织....