Spring Cloud Stream允许用户使用Spring Integration开发和运行消息传递微服务，并在本地或云中或甚至在Spring Cloud Data Flow上运行它们。只需添加@EnableBinding并将您的应用程序作为Spring Boot应用程序（单个应用程序上下文）运行。您只需要连接到总线的物理代理，如果类路径上有相关的总线实现，则这是自动的。
我正在尝试在kafka上使用spring-cloud-stream。下面是示例代码。但它似乎没有任何作用。它总是创建一个名为 "output "的主题。但是值没有被发布。...
我有一个业务应用程序，其版本如下 spring boot(2.2.0.RELEASE) spring-Kafka(2.3.1-RELEASE) spring-cloud-stream-binder-kafka(2.2.1-RELEASE) spring-cloud-stream-binder-kafka-core(...)
spring cloud stream支持json header？
我们所有的消费类应用都使用spring-cloud-stream，但我们的一个大型生产类应用(legacy...)因为spring boot版本是1.4，所以不能使用spring-cloud-stream。但是我们的一个大型生产者应用(legacy...)不能使用spring-cloud-stream，因为spring boot版本是1.4。我们尝试用...
从Spring Cloud Streams Kafka Stream应用中的处理器写入主题
我是用处理器API来做一些低级处理到一个状态存储中。关键是我还需要在存储到存储后写进一个主题。在Spring Cloud中怎么能做到 ...
我试图在同一个应用程序中消费来自不同 PubSub 主题的多个消息。其中一个是轮询，其他的应该是功能绑定。我的功能消费者不工作。@Bean ...
Spring云流Kafka消费者被长期运行的作业和max.poll.interval.ms的大值卡住了。
我们有一些长期运行的作业，也已经用Spring Cloud Stream和Kafka binder实现了。我们面临的问题是，因为max.poll.interval.ms和max.poll的默认值......
当使用 enable.idempotence true 时，Spring Cloud Stream Kafka 应用程序的启动速度极慢。
我的Scs应用有两个Kafka生产者，配置如下：spring: cloud: function: definition: myProducer1;myProducer2 stream: bindings: myproducer1-out-0: ...
我正试图从spring cloud中学习事件驱动-消息驱动的概念，我遇到了@EventListener和@StreamListener这两个注解。能否有人指导我理解基本 ...
使用GCP Pubsub的Spring云流 - 禁用对现有主题的检查。
我在GCP项目A中有一个PubSub订阅，A中运行着一个Spring Cloud Stream应用，A中的PubSub订阅引用了GCP项目B中的一个Topic foo，该应用目前只有 ...
我有一个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 , ...