Spring Cloud Stream允许用户使用Spring Integration开发和运行消息传递微服务，并在本地或云中或甚至在Spring Cloud Data Flow上运行它们。只需添加@EnableBinding并将您的应用程序作为Spring Boot应用程序（单个应用程序上下文）运行。您只需要连接到总线的物理代理，如果类路径上有相关的总线实现，则这是自动的。
[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：前缀（不支持即用型）。本质上，这使我可以放置一个信任库。...
Kafka生产者未能发送带有NOT_LEADER_FOR_PARTITION例外的消息
我们正在使用spring-cloud-stream-binder-kafka（3.0.3.RELEASE）将消息发送到我们的Kafka集群（2.4.1）。生产者线程不时地收到NOT_LEADER_FOR_PARTITION异常，...
。Net或.Net Core中是否有等效的Spring Cloud Stream？
我有一个Java项目，需要在C＃.Net Core中进行重写。 Java应用程序当前已使用SCS部署在云上。流的概念看起来很平滑，因为我们可以轻松地可视化数据流...
我有一个应用程序，我想在其中手动执行Kafka消息中的（n）ack。根据Spring Cloud文档，应使用autoCommitOffset spring cloud文档...
Spring Cloud Stream-将fasterxml ObjectNode添加到kafka的受信任包中
我正在使用Spring-cloud-stream版本3.0.4，我正在编写一个JSON合并器，它侦听多个流，将JSON存储在状态存储中，然后对其进行合并以生成输出JSON。 ...