Spring Cloud Stream允许用户使用Spring Integration开发和运行消息传递微服务，并在本地或云中或甚至在Spring Cloud Data Flow上运行它们。只需添加@EnableBinding并将您的应用程序作为Spring Boot应用程序（单个应用程序上下文）运行。您只需要连接到总线的物理代理，如果类路径上有相关的总线实现，则这是自动的。
我已阅读到，如果某个使用者接受了一条消息，但未确认在给定的时间范围内已成功处理该消息，那么将向另一个使用者提供相同的消息以保证...
如果在处理步骤期间发生故障，如何使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 ....
Spring Cloud Stream Kotlin消费者问题
我正在尝试使用Kotlin的Spring Cloud Stream。我写了一个简单的使用者，如下所示：@Bean fun log（）：Consumer {return Consumer {person：Person-> println（“ ...
当Spring Kinesis绑定程序尝试释放锁定时，应用程序停止期间的DynamoDB解锁错误
当应用程序停止时，Kinesis活页夹尝试解锁dynamoDB并抛出解锁失败异常。我在此原始帖子中关注了类似的问题，并更新了spring-integration-aws版本...
如何使用 spring-cloud-stream-rocketmq 配置多个名称服务器
尝试使用 spring-cloud-stream-rocketmq 开发微服务项目。我有默认的 RocketMQ 服务器，我的配置是 春天： 云： 溪流： 默认绑定器：ro...
使用Spring Cloud Stream Kafka活页夹重复消耗消息
[我们有几个使用Spring Boot和Spring Cloud Stream Kafka活页夹的微服务在它们之间进行通信。有时，我们会观察到消费者收到的重复消息的突发情况-经常...
spring cloud流使kafka套接字连接保持活动状态
我需要有效地配置spring-cloud-stream-kafka套接字，因为失去了与Azure EventHub的连接。基于推荐页面https：//github.com/Azure/azure-event-hubs-for -...
我正在尝试创建一个聚合器，在该聚合器中，我侦听多个记录并将它们合并为一个。合并后，我通过加入流和聚合的应用程序来等待流程事件...
在Spring Cloud Stream上使用自定义Serde序列化聚合状态存储时出错
[我正在尝试使用Spring Cloud Stream创建一个简单的功能bean，该bean处理来自KStream和GlobalKTable的消息，将它们加入，聚合它们，并将结果输出到新的流中...
如果使用者（kube pod）重新启动，spring-boot 1.5.4春季云流手动偏移提交行为
[嗨，我们一直在使用具有以下依赖项的旧spring版本和kafka 1.1 +--org.springframework.boot：spring-boot-starter-web：-> 1.5.4.RELEASE（*）+ --- org。 springframework.cloud:spring -...
StreamListener是否在内部调用MessageChannel.send（Message>消息）
在我们的应用程序中，我们使用kafka并具有一个像这样的弹簧云输入流：@Component公共接口SomeChannel {@Input（ChannelNames.SOME_INPUT）MessageChannel someInput（）; }现在是一个...
如何使用spring-cloud-stream-binder-kafka和RetryTemplate启用有状态重试？
我想知道是否有一种方法可以使用spring-cloud-stream-binder-kafka启用有状态RetryTemplate。我注意到有一个构造函数RetryingMessageListenerAdapter（MessageListener
如何向Spring Cloud Stream Binder的环境添加属性源
我已经编写了一个PropertySource，它启用spring.kafka.properties.ssl.truststore.location的classpath：前缀（不支持即用型）。本质上，这使我可以放置一个信任库。...