Spring Cloud Stream允许用户使用Spring Integration开发和运行消息传递微服务，并在本地或云中或甚至在Spring Cloud Data Flow上运行它们。只需添加@EnableBinding并将您的应用程序作为Spring Boot应用程序（单个应用程序上下文）运行。您只需要连接到总线的物理代理，如果类路径上有相关的总线实现，则这是自动的。
我决定选择SCS以避免陷入特定的消息代理。话虽如此，我还没有找到一种方法来自动或手动确认消息，而且我所有......
Kafka INVALID_FETCH_SESSION_EPOCH
我们正在使用kafka代理设置与使用Spring云流kafka运行的kafka流应用程序。虽然它似乎运行正常，但我们在日志中得到以下错误语句：2019 -...
我的消费者被绑定到匿名消费者群体而不是我指定的消费者群体。 spring：cloud：stream：kafka：binder：brokers：localhost ...
Spring Cloud StreamListener @Output KStream Serdes似乎不起作用
我有一个流监听器@StreamListener（target =“requesti”）@SendTo（“responseo”）public KStream 过程（KStream events）{//谓词
Spring Cloud Stream主题分区KStream读/写
我有多个微服务和前端API，喜欢在单独的分区上使用相同的主题事件每个域事件，我能够配置spring kafka binder发送到不同的...
Spring Integration Flow：基于没有SpEl表达式的头文件进行过滤
我有以下Spring集成流程：@Bean public IntegrationFlow checkoutEventFlow（）{return IntegrationFlows.from（EventASink.INPUT）.filter（“headers ['type'] =='TYPE_A'”）// 1 ...
如何在不使用Transformer的情况下在TestSupportBinder中获取通道
我正在尝试使用TestSupportBinder为spring cloud stream应用程序编写测试。我找到的所有例子，包括官方文件和官方github，都是用...测试处理器。
如何使用Object有效负载而不是MessageCollector中的字符串接收GenericMessage
我尝试使用MessageCollector测试通过spring-cloud-stream发送和接收消息。当我使用本机java序列化流云时一切正常，但当我改变序列化...
使用spring cloud数据流来调度作业时，应用程序实例是否已部署/取消部署？
使用spring cloud数据流来调度作业时，支持作业的应用程序是否已按计划部署然后取消部署，或者是否继续运行？我想弄清楚......
问题在与Oleg的讨论中进行了大量编辑我试图在Spring Cloud Stream中实现BigQuery的绑定器。完整的应用程序代码可在GitHub上获得。到目前为止，我已经写了......
根据本期＃1623，Binder实现和Spring Cloud Stream Refrence中的对话，我想注入Sink对象，并为输入通道订阅MessageHandler，但似乎......
Spring Cloud Stream与Kafka Stream for Exactly Once功能
如果Spring Cloud Stream能够提供Kafka Stream API提供的“Exactly Once”语义，我无法在Spring和网站上找到它们。也许没有一个配置/ ...
我正在寻找一个从apache kafka读取消息的spring boot服务，通过http请求来自其他服务的消息所指示的记录，处理它们，将一些数据保存到...
Spring Cloud Stream通过配置延迟创建Exchange
我有一个用例，其中消息必须以一定的延迟进行重新处理，并且还希望在重试之间引入指数退避，文档中提到的ReRouteDlqApplication ...
具有自动扩展订阅者的Spring Cloud Stream是否会使用云pubsub绑定器处理相同的消息？
我在Google Appengine上有两项服务，可以自动增加2到20个实例的负载。我刚刚添加了spring cloud stream和pubsub binder来发布通信消息......
Spring Cloud Stream GCP如何重新排队失败的消息
根据这里的文档，目前支持的绑定器（Rabbit和Kafka）依赖于RetryTemplate。而对于GCP？我的项目的详细信息Spring Boot Version 2.1.3.RELEASE Dependency pom.xml
如何从下一个Transformer模块中的Spring云数据流聚合器应用程序输出中提取Collection有效负载记录
我正在使用SCDF [Spring Cloud Data Flow]并且在我的流中我正在聚合有效载荷，并且在下一个变换器模块中我想获得接收到的有效载荷的大小[这是一个集合对象...
spring-cloud-stream Kafka使用者是否会消费服务停止时发送的消息？
我有一个春天云流Kafka消费者服务，其中确认是手动完成的。提供固定的消费者群体。 spring.cloud.stream.bindings.input.group = sampleconsumergroup ......
Spring启动测试失败说，由于缺少ServletWebServerFactory bean，无法启动ServletWebServerApplicationContext
测试类： - @ RunWith（SpringRunner.class）@SpringBootTest（classes = {WebsocketSourceConfiguration.class，WebSocketSourceIntegrationTests.class}，webEnvironment = SpringBootTest ....
spring cloud stream - Spring云流应用程序可以明确退出吗？
我不确定我的理解是否正确。我们启动了Spring云流应用程序并订阅了一个主题。该应用程序将运行并监控新消息的主题，除了我们...