Spring Cloud Stream允许用户使用Spring Integration开发和运行消息传递微服务，并在本地或云中或甚至在Spring Cloud Data Flow上运行它们。只需添加@EnableBinding并将您的应用程序作为Spring Boot应用程序（单个应用程序上下文）运行。您只需要连接到总线的物理代理，如果类路径上有相关的总线实现，则这是自动的。
Spring Cloud Data Flow UI-运行时选项卡从不加载
我已经尝试了一些基本的教程来在Spring Cloud数据流中创建和部署流应用程序。每当我尝试部署应用程序时，spring cloud数据流就会挂起。甚至早于...
Spring-cloud-stream MessageConversionException
我有一个@StreamListener，它接受一个@Payload字符串。为了测试此Listener类，我使用嵌入式Kafka编写了Junit类。我在运行测试类Error时遇到错误...
无法通过Kafka测试在Spring Cloud Stream中读取JSON
我有一个简单的应用程序，该应用程序使用Spring Cloud Stream和Kafka接收消息并写入另一个主题。我正在尝试根据一些教程编写单元测试，但是我得到了...
[我们有一个使用Kafka的spring cloud stream应用程序。要求是，在生产者端，必须将消息列表放在事务的主题中。 ...
我正在使用RabbitMQ活页夹。当消费消息发生异常时，Spring Cloud Stream允许开发人员重试。 RabbitMQ连接丢失时，生产者可能会失败。我们怎么能...
Spring Cloud流：Kafka Sink收到备用消息
我正在尝试使用kafka绑定构建一个简单的云流应用程序。让我描述一下设置。 1.我有一位生产者正在为主题topic_1进行生产。 2.有一个流活页夹，绑定topic_1 ...
我使用的是流卡夫卡使用春云流。我做了一个汇总数据时，正在从一个话题消耗。该数据在我定义了好几家店结束。当停止应用程序，并...
我需要消耗错误消息，并根据该故障的原因或者重试或丢弃该消息。为了测试这个，我明确地抛出一个运行时异常，从我code.I看到...
我试图创建一个简单的程序从卡夫卡话题打印Kstream。我经常收到的NPE和我完全没了主意。我用弹簧云流 - 粘合剂 - 卡夫卡流...
Spring Kafka，Spring Cloud Stream和Avro兼容性未知魔术字节
我在反序列化来自Kafka主题的消息时遇到问题。消息已使用spring-cloud-stream和Apache Avro进行了序列化。我正在使用Spring Kafka读取它们，并尝试反序列化...
春季云数据流流java.lang.OutOfMemoryError：Java堆空间
我在写我自己的春天云流处理器，它接受一个I D作为输入参数，下载相应的文件，并将其发送到输出。这些文件可以像800MB大。输出对象...
获得DataFlowClientException春季云数据流
当我想给下面的命令外壳我收到以下错误。可否请您让我知道为什么我收到这个错误。我想执行下面的链接程序的Maven ...
春季云溪版本1.3.3我很好奇有关如何安装一个消息处理一组绑定？对于每个绑定，我有非常相同的逻辑：... @StreamListener（“TOPIC_1”）...
我已经配置了带弹簧的云流弹簧启动的基于应用程序。我想在KStream工作，但我不断收到错误“java.lang.IllegalArgumentException异常：方法必须声明”。 ...
休息或消息代理或用于整合内部部署和基于云泉启动应用程序的一些其他方法
我有2个春天启动应用程序内部部署柜员应用基于云从所有柜员应用柜员应用程序，如果离线工作（汇总数据多租户应用...
对不起，这个问题太普通，但有人对如何与卡夫卡嵌入式执行生产者和消费者测试的一些教程或指南。我已经试了，但也有几个版本？
如何在Spring Cloud DataFlow中注册应用程序？
我从Spring Cloud DataFlow开始，我已经通过Docker Compose运行了一个实例，并通过示例应用成功创建了Streams。我自己编写了一个Source和Sink应用程序，但我不是...
如何从Spring云流中读取Kafka Message Key？
在这里输入代码我正在使用Spring云流来消费来自Kafka的消息。是否可以从代码中读取Kafka消息密钥？我有一个Kafka主题，通常有两种类型......
spring cloud stream和gcp pub sub，binder问题
我尝试使用GCP的Pub Sum作为活页夹在本地运行SCS应用程序。 K m mmkkkk。 Mmm org.sm.Mpringframework.cloudkki spring-cloud-gcp-starter-pubsub M这是configl @Configu @ ...
Kafka主题，Spring-cloud-stream频道和Spring-cloud-stream目的地之间的差异
劳驾!我从队友那里得到了同样的问题。他们问我Kafka话题，Spring云流频道和Spring Cloud流目的地有什么不同点。我们试着......