Spring Cloud Stream允许用户使用Spring Integration开发和运行消息传递微服务，并在本地或云中或甚至在Spring Cloud Data Flow上运行它们。只需添加@EnableBinding并将您的应用程序作为Spring Boot应用程序（单个应用程序上下文）运行。您只需要连接到总线的物理代理，如果类路径上有相关的总线实现，则这是自动的。
使用Spring Cloud Stream将RabbitMQ消费者绑定到现有队列
我创建了使用RabbitMQ web-UI主题交换TX并绑定到交换机两个队列TX.Q1和TX.Q2，每个队列相应地绑定路由键rk1和rk2，并产生一些消息给...
Spring-Kafka vs. Spring-Cloud-Stream（Kafka）
使用Kafka作为微服务架构中的消息传递系统，使用spring-kafka与spring-cloud-stream + spring-cloud-starter-stream-kafka有什么好处？春云流......
使用spring-boot：1.5.1和spring-cloud-stream时无法启动bean'inputBindingLifecycle'
使用spring-boot时我得到下面提到的错误：1.5.1但是在使用spring-boot时没有：1.4.4有没有人遇到过这个？ package org.test; import lombok.Data; import lombok.ToString;进口......
Spring Cloud Stream如何防止应用程序的实例接收重复的消息？
Spring Cloud Stream至少基于一次方法，这意味着在极少数情况下，重复的消息可以到达端点。 Spring Cloud Stream是否保留已收到的缓冲区...
我正在尝试使用Spring Cloud Stream创建一个kafka Consumer，以便使用自定义标头（operationType）监听在任何Spring上下文之外构建的Kafka消息。我正在使用Spring Boot 1.5.x / ...
spring cloud stream- consumer config无法正常工作
我使用的是spring boot 2.0.3-RELEASE版本。这是我的配置文件。当我启动我的消费者时，它以默认配置启动。它们不会被我指定的配置覆盖。春天：云：......
可以使用Spring云流kafka-streams创建GlobalKTable的任何示例？
如果有多个GlobalKTable创建和连接的Spring云kafka流示例，请分享。
人们通常如何处理流应用程序的错误？特别是我正在使用Spring Cloud Dataflow管道。例如，在典型的源中处理器|下沉管道，如果处理器......
我们正在使用Spring Cloud Stream（使用Kafka活页夹）构建事件驱动的微服务，并查看用于跟踪未作为http端点公开的Micorservices的选项。请建议。一世 ...
使用application.yml springboot和config server在RabbitMQ服务器上创建virtualHost
Virtualhost没有基于配置在RabbitMQ服务器上创建我是否确保在RabbitMQ上使用VH aka虚拟主机。我错过了一些配置。请找配置...
我们的代码完全被动，使用Webflux。我们想要向Kafka队列发送消息，并希望以反应方式进行。我看到有一个spring-cloud-stream-reactive依赖，它支持Reactive ......
如何确保Spring Cloud Stream Listener等待处理消息，直到Application在Start上完全初始化？
使用Spring Cloud Stream Kafka应用程序，我们如何确保流监听器等待处理消息，直到完成某些依赖性任务（例如参考数据填充）？以下app无法...
Spring Cloud Stream Kafka Binder autoCommitOnError = false获得意外行为
我使用的是Spring Boot 2.1.1.RELEASE和Spring Cloud Greenwich.RC2，spring-cloud-stream-binder-kafka的托管版本是2.1.0RC4。 Kafka版本是1.1.0。我设置了以下内容......
Spring Cloud Stream Kafka活页夹无法使用密钥发布到DLQ
当使用@StreamListener处理失败并且Spring Cloud Stream Kafka binder尝试将消息重新路由到DLQ时，我收到以下异常。使用Spring Cloud Edgware.SR5。组织....
是否可以在Spring Cloud Stream中拥有多个@StreamListener？
我使用Sprin云strema Kstream。我测试了一个主题和一个@StreamListner。没关系。我修改了两个KStream Input的代码。 （两个@StreamListener）但是，春云错误.. *********************** ...
Elastic APM是否支持Spring Cloud Stream
我是Elastic APM的新手，不知道它如何支持不同的框架。我可以从文档中看到APM支持Spring Boot。我用APM测试了一个Spring Boot应用程序...
Spring Cloud Aws kinesis Binder组中的所有JVM以不同的间隔消耗相同的消息
我们有三个容器连接到Kinesis流作为使用Spring cloud AWS kinesis binder的消费者。我们使用了使用者组来跨三个容器进行负载平衡。要求是......
如何通过多个StreamListener Spring Cloud Stream和Kafka流来收听多个主题
我想听听下面代码中的两个Kafka主题，并且有两个源事件需要处理并转换为另一个事件。所以我想把这两个事件合二为一......
我们正在研究优化磁盘空间使用的选项。在这样做时，我们通过kafka分区查看保留的磁盘空间。现在错误主题使用相同数量的分区......
我们正在为Kafka使用Spring Cloud Stream，我们正在寻找具有消费者API的Exactly Once Semantics
我们正在使用Spring Cloud Stream for Kafka并寻找Exactly Once Semantics。我们有一个解决方案，正常工作正常1）从生产者2启用Idempotent和交易）...