Spring Cloud Stream允许用户使用Spring Integration开发和运行消息传递微服务，并在本地或云中或甚至在Spring Cloud Data Flow上运行它们。只需添加@EnableBinding并将您的应用程序作为Spring Boot应用程序（单个应用程序上下文）运行。您只需要连接到总线的物理代理，如果类路径上有相关的总线实现，则这是自动的。
我有一个spring boot应用程序，它有两个功能Http请求和kafka消息处理。我想让这个应用程序以从application.yml中启用的模式运行，即如果用户 ...
我有一个Spring Cloud Stream应用程序，处理死信队列。在这里，我处理转发到DLQ主题的记录，如下所示-- @SpringBootApplication @EnableBinding(Processor.class) public ...
用他们的test-binder测试spring-cloud-stream总是会抛出MessageDeliveryException。Dispatcher没有通道的订阅者。
我试图为我的消息生产者写测试。但每当我尝试使用注入的Bindings发送消息时，我得到以下错误，原因是：org.springframework.integration...。
我参考了这里发布的示例。我正试图一起运行多个 spring cloud 流应用程序。这里，第一个的输出被作为输入给其他。以下是我想做的事情。@...
我开始涉猎Spring云流和它的云功能支持。我在这里上传了一个示例项目来阐明这个问题->https:/github.comnmarquesantosspring-cloud-function-...
我想用多个消息来测试Spring Cloud Stream Sink。比方说，我有一个这样的处理器类。@Component @EnableBinding(Processor.class) public class TestProcessor { @Autowired ...
支持为spring cloud流绑定中的每个消费者绑定定义spring.json.key.type。
在遵循JsonSerdeExample之后，我能够直接将话题中的数据消耗到我的Java对象中。下面的属性完成了所有的魔法 spring.json.key.default.type: com.xxxx......。
在Spring Cloud Stream Kafka中，消息在Reactive中被省略了。
我有一个spring云应用，使用spring reactive core监听两个主题，每个主题有10个分区。在消费者中，我只是简单地读取消息并打印主题、分区和 ...
使用Spring Cloud Data Flow的流式分隔文件
我正试图从远程Linux服务器加载一个以标签分隔的文件，并使用Spring Cloud Data Flow将其加载到Postgres数据库中，但在选择适当的源和汇方面遇到了困难。对于源，我 ...
如何在Spring Cloud Stream Kafka绑定中写一个订阅主题的方法？
我想用KafkaListener写一个消费者方法来订阅一个主题。我找到了一个答案，它建议这样做--@KafkaListener(id = "foo", topics = "dead-out") public void dlq(Message)
我在Spring云流kafka流binder上工作。在我的消费者Bean方法中，我想返回以List of String为值的KStream--@Bean public Function , ...
Spring Cloud Stream应用程序中的timestampExtractorBeanName设置不能覆盖默认值。
我的 Spring Cloud Stream 应用程序使用 Kafka Streams Binder，有以下属性： spring.cloud.stream.bindings: windowStream-in-0: destination: input windowStream-out-0: ...
当每个消息的处理需要很长的时间时，6个Kafka消费者的最大吞吐量策略。
考虑一下这个场景。Kafka主题有6个分区 Spring Java Kafka Consumer Application有6个副本，这样每个副本都处理其中一个分区。我面临的问题是...
如何在Spring Cloud Stream App中反序列化MessagePack？
我正试图使用Spring Cloud Stream创建一个Kafka流应用，但在反序列化输入消息时遇到了困难，因为这些消息的值已经使用MessagePack进行了编码。如果有人能帮忙，我将会...
Spring Cloud Stream--在运行时向多个动态目的地提供路由。
我有一个用例，在这个用例中，我需要向多个在运行时确定的Kafka topicdestinations进行输出。我试图通过使用返回Flux&结合具有多个输入和输出参数的Functions。
从Spring Boot 2.2.2升级到2.3.0后，Kafka消费者指标消失了。
问题：我们将Spring Boot版本从2.2.2升级到2.3.0，在2.2.2的Prometheus端点中看到的所有kafka_consumer_*指标在2.3.0中都不可见。例如，...
减少Spring Cloud Kafka Streams应用中的锅炉模板
在我的Spring Cloud Kafka Streams应用中，我想加入一个KTable 到一个KT表 . 我的应用程序的输入已经使用MessagePack编码，所以我已经为Serdes定义了 ...
Spring Cloud Data Flow自定义Scala处理器无法从启动应用程序发送接收数据（SCDF 2.5.1 & Spring Boot 2.2.6）。
我一直在努力为Spring Cloud Data Flow在Scala中创建一个简单的自定义处理器，并在向启动应用程序发送接收数据时遇到了问题。我一直在...
如何在Spring云Dataflow中使用httpclient处理器？
我正在尝试使用spring cloud dataflow。我的具体使用案例是将GET请求的响应转储到一个日志中。我试图使用httpclient处理器来完成这个任务。但我不明白为什么它......
当消息不能被RabbitMQ路由时，Publisher确认会给出ACK。
我正在做一个小项目来检查RabbitMQ的Publisher Confirms与Spring Cloud Stream 3.0.1的工作情况。我有一个特殊的情况，当一个消息被发送到RabbitMQ的交换，但这......