Spring Cloud Stream允许用户使用Spring Integration开发和运行消息传递微服务，并在本地或云中或甚至在Spring Cloud Data Flow上运行它们。只需添加@EnableBinding并将您的应用程序作为Spring Boot应用程序（单个应用程序上下文）运行。您只需要连接到总线的物理代理，如果类路径上有相关的总线实现，则这是自动的。
未发布到Kafka的Spring Cloud Bus事件（RemoteApplicationEvent）
我正在使用Spring Cloud Bus将事件发布到kafka，以便另一个实例可以侦听同一事件。事件正在触发，但尚未发布给kafka。我正在使用带有...
将Spring Websocket添加到服务时未使用Spring Cloud Stream的自定义MessageConverter
我有一个Scs微服务，它使用来自一系列Kafka主题的消息，这些主题都共享相同的抽象类。我已经注册了一个自定义MessageConverter来反序列化...
在将消息发送到Spring Cloud Streams中的DLQ之前添加自定义信息
我仅通过使用属性来使用Spring Cloud Streams和默认的Spring Retry机制。它运行良好，可以重试消息，然后转到DLQ。到目前为止一切都很顺利。现在出现了问题...我...
[我有一个包含2个主题的spring boot kafka流应用程序，考虑主题A和B。主题A具有16个分区，主题B具有1个分区。考虑将应用程序部署在1个实例中，该实例具有num ....
Spring cloud stream Rabbitmq绑定器-Spring Cloud函数错误处理
我正在使用具有春天云功能的春天云流兔子活页夹，并定义如下的监听器：public Function ，Flux > foo（）{//一些代码} I ...
在我们的应用程序中，我们有多个主题，其中一些主题将创建为16个分区，而某些主题将创建为1个分区。是否有任何spring.cloud.stream.kafka.bindings ...
我正在尝试了解有哪些可能的工具包/框架可用于实现以下目标。开发人员通常应在其中将数据流（一系列步骤）配置为...
无法在春季云kafka中按主题/活页夹级别设置Serde，生产者和消费者属性
我正在尝试使用Spring Cloud Kafka活页夹启动简单的发布订阅应用程序。但是我无法在应用程序中设置序列化程序，DeSerialzer属性以及其他生产者和使用者属性。...
带有AWS MSK的Spring Cloud Stream-如何在AWS上使用和部署？
我已经在Kafka上使用Spring Cloud Stream已有一段时间了。我有一个样本SCS-Producer，它将数据泵出到输出主题。下面是我的生产者代码：-@EnableBinding（Source.class）...
将自定义标题添加到Spring Cloud Stream（使用Spring Reactor）
作为Spring Reactor的新手，我正在尝试使用Spring云流（使用rabbitMQ）来流数据。在将消息发送到队列之前，我需要添加一些自定义标头。我的spring-cloud -...
[我试图绕过Kafka Streams，并提出一些我似乎无法自行解决的基本问题。我了解KTable和Kafka State Stores的概念，但是... ...>
带有键的键值，消息类型为“ Spring cloud stream SOURCE
我正在尝试使用Spring Cloud Stream发送带有键，值对的消息。我找不到为此的任何API。 org.springframework.messaging.MessageChannel仅将有效负载作为发送的一部分...
如何使用Spring Cloud Stream Supplier将密钥消息发送到Kafka
我想使用Spring Cloud Stream生成发给Kafka的带键（带有特定键的消息）消息。 @SpringBootApplication公共类SpringCloudStreamKafkaApplication {public static void main（...
使用Spring-cloud-stream-kafka-stream的活页夹问题
我正在尝试使用春季云流kafka流阅读kafka。然后将事件汇总到一个分钟的时间窗口中，然后将其归类到其他主题。然后，我需要从...
Kafka流：PolicyViolationException：主题复制因子必须为3
我目前正在构建一个应用程序，该应用程序可以写入kafka主题，并听取相同的主题以从中生成ktable并将其具体化到商店中。我正在运行的代码基于...
Spring Dataflow流文件接收器-需要写入单独的文件
我一直在使用Spring Cloud Dataflow。我已经编写了一个定制的Cloud Stream Processor应用程序，该应用程序接收特定类型的XML文档，并将其拆分为较小的XML文档。 ...
不要在Spring Cloud Stream的反应式功能中将消息标记为已确认
我正在使用带有Java 13的Horsham SR1版本的spring-cloud-stream。我正在使用Google Pub / Sub作为底层消息系统。我有一个类似这样的反应函数：@Bean public Function＆...
Spring Cloud Stream kafka生产者，生产动态kafka主题
我想使用Spring Cloud Stream框架创建一个kafka端点，它将在/ {topic_name}上添加一个http post api。如何动态更改spring.cloud.stream.bindings。
Spring Cloud Kafka基于标题信息流动态消息转换
我正在尝试使用Spring Cloud Kafka Streams处理包含不同类型消息的Kafka主题消息。例如，我们从主题接收到JSON消息，该消息可以是...
如何在Spring RestController内部产生和使用RabbitMQ消息并将其发送回用户
大家好，大家好。我正在开发一个Spring Boot应用程序。这是我的问题。我有一个带有后映射的Spring RestController，可以接收一些数据。然后，我需要发送...