Spring Cloud Stream允许用户使用Spring Integration开发和运行消息传递微服务，并在本地或云中或甚至在Spring Cloud Data Flow上运行它们。只需添加@EnableBinding并将您的应用程序作为Spring Boot应用程序（单个应用程序上下文）运行。您只需要连接到总线的物理代理，如果类路径上有相关的总线实现，则这是自动的。
我收到有关此问题的建议，并发表评论，说我可能没有所需的Exchange，因为我的队列已经存在。因此，我手动将其全部删除。但是，当重新...
我要执行以下操作：当一条消息失败并落入我的死信队列时，我想等待5分钟，然后将同一条消息重新发布到我的队列中。今天，使用Spring Cloud Streams和...
如Spring Cloud https://cloud.spring.io/spring-cloud-stream/multi/multi__configuration_options.html的文档中所述，可以将通道绑定到多个目标。 ...
我正在尝试将Spring Cloud Stream应用程序Chelsea.SR1迁移到Horsham。该项目没有活页夹，但使用Spring消息传递和集成来集成自定义源和接收器。它...
我有一个目前在下面使用Spring Cloud Streams和RabbitMQ的项目。我已经根据文档实现了逻辑。参见下文：@Component公共类ReRouteDlq {private ...
我有一个使用Spring Cloud Streams-RabbitMQ在微服务中交换消息的项目。对我的项目至关重要的一件事是，我一定不会丢失任何消息。为了...
我有kafka输入和输出主题。我要做的是我在主题A中编写内容，并希望在主题B中接收消息但具有缓冲功能。我的代码如下所示：@Bean public Function ] >>>> buffer()，而不是window()是您只需要将结果作为集合而不是Flux返回的运算符。 如果您还想从结果集合中过滤重复项，则可以通过传递HashSet供应商作为第二个参数来使用Set而不是List来存储值： flux -> flux.buffer(10, HashSet::new)
将Kafka Streams代码迁移到Spring Cloud Stream吗？
Spring云流将支持下面的Kafka Streams应用程序。以下是Kafka示例应用程序摘录中的代码。任何反馈或支持，表示赞赏。 ... StreamsBuilder ...
我正在寻找一种解决方案，以在下游服务关闭时暂停应用程序本身的运动流中的消息使用。我正在使用spring-cloud-stream-binder-kinesis。有...
我阅读了有关Spring Cloud Stream 3.0的文档，以使用java.util.function。[Supplier / Function / Consumer]理解了新的内容，以代表生产者，消费和生产，消费者等...
我在测试春季云流服务（写入Kafka流）时遇到问题。它基于以下baeldung简介。这是服务代码（省略详细信息）@ ...
无法从Spring Cloud Stream Kinesis绑定程序链中的任何提供程序加载AWS凭证
如果不使用系统级别的默认配置，我将无法连接到Spring Cloud Stream Kinesis活页夹（1.2.0.RELEASE）中的AWS kinesis。仅当系统已经...
是否有可能使方法（处理程序）从Spring Cloud Stream中的多个入站通道接收消息？
假设我对接收器接口公共接口具有此定义Sink {@Input（“ input”）SubscribableChannel input（）; @Input（“ anotherInput”）SubscribableChannel anotherInput（）; }和...
如何指定使用Spring Cloud Stream向RabbitMQ发送消息的超时时间？
我们在发送消息的过程中遇到了网络问题，这导致所有线程处于“阻塞”状态。我们正在使用org.springframework.cloud:spring-cloud-stream:2.0.1.RELEASE和org ....
Spring cloud stream-初始化Kafka绑定程序时的通知
我的春季云流应用程序中有一个简单的Kafka生产者。在我的Spring应用程序启动时，我有一个@PostConstruct方法，该方法执行一些协调，并尝试将事件发送到...
Spring Cloud Data Flow将时间戳添加到文件名
我正在尝试将开箱即用的Source和Sink流应用程序与Spring Cloud数据流一起使用。我正在尝试将文件从一个文件夹移动到另一个文件夹。当文件到达接收器I ...
我试图通过修改max.poll.interval.ms，session.timeout.ms和heartbeat.interval.ms来解决CommitFailedException问题。我试图在应用程序中更改这些值。...
SerializationFailedException：具有kpl-kcl-enabled：true的Spring Cloud Stream Kinesis绑定程序：true
我目前正在评估在新项目中使用春季云流运动学绑定器的可能性，但是我遇到了一些问题。当我启用了kcl-kpl时：false一切正常。但是...
无法通过Spring Cloud streamng在Kafka Ktable中看到任何消息
我已经使用Spring Cloud流API编写了一个Kafka流应用程序，但无法在KTable中看到任何消息。我无法追踪问题。任何指针或帮助表示赞赏。下面...
具有多种消息类型的卡夫卡和主题（Avro）：消费者（由于在类路径上缺少类，Spring Cloud Spring失败了）>
主题包含两种类型的消息：PaymentStarted和PaymentCompleted。与消费者有两种分离的微服务。所以：Microservice_1，有consumer1应该抓住PaymentStarted ...